GOCQL is the golang driver for connecting to Cassandra.
2 ответа

gocql SELECT * не возвращает все столбцы

Я столкнулся с этим странным поведением, пытаясь реализовать некоторые счетчики для моего приложения. По сути, я сделал счетную таблицу примерно так: CREATE TABLE stats_dev.log_counters ( date text PRIMARY KEY, all counter ); Затем у меня есть неско…
19 янв '15 в 21:26
1 ответ

gocql блокирует слишком много одновременных запросов на чтение (golang, Cassandra)

Используя GOCQL (Golang, Cassandra), я делаю до 128 запросов, а потом все зависает. Я верю в функцию getTicksForCassandraKey(), которую я правильно выпускаю, но не уверен. GOCQL поддерживает только до 128 одновременных запросов, поэтому я должен что…
25 май '17 в 15:33
1 ответ

Как получить количество строк, возвращаемых запросом, используя gocql

Я использую библиотеку gocql, которая описана здесь: https://godoc.org/github.com/relops/cqlc/cqlc и пытаюсь написать вызов API в golang, который будет запрашивать все элементы в моем база данных, которая заполняет определенное поле и возвращает общ…
13 июн '16 в 23:52
1 ответ

golang gocql.NewCluster undefined отсутствует поле или метод

Я пытаюсь запросить тестовое пространство ключей, как: package main import "fmt" import _ "github.com/gocql/gocql" var ( gocql string ) func main() { // connect to the cluster cluster := gocql.NewCluster("127.0.0.1") cluster.Keyspace = "dbaccess" se…
14 янв '16 в 00:49
1 ответ

Получение "gocql: нет ответа на запуск соединения в течение тайм-аута" при подключении к Cassandra

Попытка подключиться к Cassandra (v 3.10.0) с помощью gocql (Go: 1.8.3). Вот ошибка gocql: невозможно набрать контроль. conn [hostIP]: gocql: нет ответа на запуск соединения в течение тайм-аута. panic: gocql: невозможно создать сеанс: control: невоз…
02 фев '18 в 04:41
1 ответ

Инициализируйте gocql ips, используя константу

Мне нужно инициализировать gocql с несколькими ips, я хочу передать ips из переменной / константы. Как передать что-то вроде gocql.NewCluster(ipvalues) Вместо того, чтобы использовать gocql.NewCluster("127.0.0.1", "127.0.0.2") я хочу передать список…
23 авг '18 в 10:59
1 ответ

Как проверить нестандартную эквивалентность объекта в шаблоне Голанга

Я выводить раскрывающийся список с использованием шаблона HTML, как показано ниже: {{range .Organisations}} <option value="{{.Uuid}}">{{.Name}}</option> {{end}} Я хочу указать, что один из пунктов должен быть выбран путем eq компаратор. …
07 ноя '14 в 04:24
0 ответов

Как проверить, применяется ли CQL-запрос

У меня есть API-сервер, написанный на golang в передней части Cassandra, поэтому я использую gocql в качестве драйвера. Я хочу вернуть ошибку, если кто-то пытается создать дублированные записи в Cassandra, поэтому мне нужна не только идемпотентная о…
09 янв '19 в 15:26
0 ответов

ScanCAS возвращает ErrNotFound для запросов UPDATE

Когда я выполняю запрос UPDATE для таблицы счетчиков с помощью gocql, ScanCAS / Scan всегда возвращает ErrNotFound, даже если запрос применяется. Описание таблицы и код ниже: CREATE TABLE tests.tests_revisions_counters (project text, resourcename te…
17 янв '19 в 13:39
1 ответ

Выяснение состояния страницы с помощью драйвера Cassandra GOCQL (Golang)

Я пытался обернуть голову, как работает подкачка в Apache Cassandra с функциями драйвера в GOlang. У меня есть следующий код для извлечения строк /// Assume all other prerequisites. session, _ := cluster.CreateSession() session.SetPageSize(100) var …
28 фев '19 в 15:34
0 ответов

GoCQL cluster.CreateSession() выводит ошибку на стандартный вывод

В этом коде func InitDB(keyspace string) (*gocql.Session, error) { //********************************************************************************** // connect to the Cassandra cluster //***********************************************************…
11 дек '18 в 02:51
2 ответа

Как создать пространство клавиш в Кассандре с помощью gocql

Есть ли способ создать новое пространство ключей в Кассандре с помощью gocql?
12 мар '18 в 21:12
1 ответ

gocql - использование функций timeuuid Cassandra 3

В cqlsh я могу выполнить что-то вроде: SELECT id FROM names WHERE name = 'dave' AND id > maxTimeuuid('2015-04-05 00:05') AND id < minTimeuuid('2019-01-01 00:05'); ... это возвращает список, как и ожидалось. id ---------------------------------…
05 апр '18 в 22:13
2 ответа

Как сделать INSERT, если не существует в gocql

Я читал http://godoc.org/github.com/gocql/gocql И все же я не понимаю, как сделать INSERT - ЕСЛИ НЕ СУЩЕСТВУЕТ с gocql. Он заявил, что func (* Query) ScanCAS func (q * Query) ScanCAS (dest... interface {}) (применяется bool, ошибка err) ScanCAS выпо…
10 ноя '14 в 16:07
1 ответ

Использовать размер страницы или нет

У меня есть таблица в Кассандре с множеством строк. Не безопасно, что я получаю все строки сразу. Я использовал PageSize, но он также возвращает все строки. Верно ли это? Есть ли разница между использованием и неиспользованием? А как насчет PageStat…
24 июл '18 в 07:42
1 ответ

GoLang, плохое показание из среза

Я довольно новичок в GoLang, и мне нужна помощь. Я делаю простое приложение API. Вставка структур API в слайс выглядит следующим образом: type Struct struct { //some records } var structs []Struct //slice func SetStruct(w http.ResponseWriter, req *h…
09 сен '18 в 11:41
1 ответ

Транзакция в Кассандре и я использую gocql

Как вы можете убедиться, что один пользовательский вкладыш не подвержен влиянию другого пользователя? Как транзакции... Используете ли вы пакетное задание в сочетании с IF NOT EXISTS? BEGIN UNLOGGED BATCH INSERT INTO atable ("user1") value (10) INSE…
03 апр '15 в 15:59
1 ответ

Получение ошибки тайм-аута с Gocql

Я получаю следующие ошибки при вставке данных в Cassandra. я использую gocql клиент для Кассандры. {"error": "gocql: слишком много тайм-аутов запроса на соединение","status":500} {"error": "gocql: от cassandra в течение периода ожидания не получено …
21 мар '17 в 09:17
0 ответов

"go test" возвращает ошибку "gocql: от cassandra в течение периода ожидания ответа не получено".

Поэтому я хочу протестировать API, который взаимодействует с Cassandra на моей локальной машине. В моем func TestMain(m *testing.M) функция, я хочу очистить таблицы перед запуском тестов. TestMain функция выглядит так... func TestMain(m *testing.M) …
21 май '17 в 23:16
1 ответ

Сделать блокирующий / непротиворечивый / предсказуемый ответ / запрос на ScyllaDB через GoCQL

Иногда при запуске команды показывается таймаут (gocql: no response received from cassandra within timeout period), например: package main import "fmt" import "github.com/gocql/gocql" import "time" import "log" func main() { clust := gocql.NewCluste…
16 май '17 в 05:13