Описание тега datastax-python-driver

Драйвер DataStax Python для Apache Cassandra
1 ответ

Кассандра Python драйвер ReadTimeout

Я пытаюсь запустить запрос cqlsh, используя официальный драйвер python: >>> session.execute('select count(*) from cassandra_table') и я получаю следующую ошибку: ReadTimeout: Error from server: code=1200 [Coordinator node timed out waiting …
1 ответ

Скопируйте строку из базы данных Cassandra, а затем вставьте ее с помощью Python

Я использую плагин DataStax Python Driver для Apache Cassandra. Я хочу прочитать 100 строк из базы данных и затем вставить их снова в базу данных после изменения одного значения. Я не хочу пропустить предыдущие записи. Я знаю, как получить мои строк…
1 ответ

Используйте встроенную функцию cassandra `now()` для генерации TimeUUID с моделью в драйвере Python

У меня есть код как import time from uuid import uuid4 import cassandra from cassandra.cqlengine.models import Model from cassandra.cqlengine.query import BatchQuery from cassandra.cqlengine import columns, connection from cassandra.cqlengine.manage…
1 ответ

Определить модель CQLEngine динамически, используя тип

Я использую Object Mapper драйвера питона Datastax Cassandra для определения столбцов таблицы cassandra во время выполнения (требования такие же). Имя таблицы и столбца и типы столбцов разрешаются во время выполнения. Я пытаюсь определить модель cas…
1 ответ

Состояние Cassandra Ring с использованием драйвера CQL python

Я пытаюсь получить здоровье кластера cassandra, есть ли способ получить это с помощью драйвера Cthon python? Ранее я использовал pycassa для модели данных, основанной на экономности: https://github.com/datastax/python-driver Есть ли способ получить …
1 ответ

Python Cassandra Driver: проблема с кодировкой при вставке

Я разрабатываю простой модуль python, который считывает данные из файла tsv и загружает их в таблицу пространств ключей Cassandra. Я начал с просмотра примеров, представленных Datastax, и все было в порядке, поэтому я начал кодировать. Программа пра…
1 ответ

Cassandra execute_async запрос потерять данные

Мне нужно вставить огромный объем данных с помощью драйвера Python DataStax для Cassandra. В результате я не могу использовать запрос execute (). execute_async() намного быстрее. Но я столкнулся с проблемой потери данных при вызове execute_async(). …
0 ответов

cassandra.cluster.NoHostAvailable неизвестное исключение

Ниже приведен мой код на python. Я читаю ключи из CSV-файла и удаляю их в базе данных. Некоторое время он работает нормально и выдает ошибку тайм-аута. Я не вижу проблем с сборкой мусора, и здоровье узла работает нормально. Traceback (most recent ca…
1 ответ

DataStax Cassandra cassandra.cluster.NoHostAvailable

Я постоянно получаю эту ошибку при нормальных условиях. Я использую драйвер Python Cassandra (v3.11) для локального подключения с включенным RPC. Проблема возникает через некоторое время. При этом предполагалось, что это связано с максимальным колич…
1 ответ

Предупреждение Кассандры о CQLENG_ALLOW_SCHEMA_MANAGEMENT

Когда я запускаю свои скрипты Python, использующие Cassandra, я получаю следующее предупреждение: /home/ubuntu/.local/lib/python2.7/site-packages/cassandra/cqlengine/management.py:545: UserWarning: CQLENG_ALLOW_SCHEMA_MANAGEMENT environment variable…
25 июн '19 в 02:33
0 ответов

Драйвер Datastax Python Cassandra и CQLSH дают разные результаты

У меня есть система Cassandra в EC2 с 3 узлами, работающими в 3 экземплярах (внутри контейнеров Docker), с репликацией 3, которые работают нормально. Чтобы выполнить некоторые тесты локально, я создал снимок данных и загрузил его локально на один уз…
1 ответ

Cassandra пишет дросселирование с несколькими клиентами

У меня есть два клиента (отдельные док-контейнеры), оба пишут в кластер Cassandra. Первый - это запись данных в реальном времени, которые поступают со скоростью, с которой может справиться кластер, хотя и с небольшим запасом емкости. Это считается в…
06 июн '19 в 12:28
1 ответ

Версия протокола драйвера Cassandra Python и ограничения на количество подключений не совпадают

Я использую версию драйвера Python для Datastax:3.23 Версия Cassandra: версия DSE 5.1.16 Вывод cqlsh дает следующее: [cqlsh 5.0.1 | Cassandra 3.11.3.5116 | DSE 5.1.16 | CQL spec 3.4.4 | Nativeprotocol v4] cluster = Cluster(['X.X.X.X'],port=9042,auth…
1 ответ

Пакетная вставка в несколько таблиц с использованием операций модели DataStax в Cassandra

Следуя совету DataStax "использовать примерно одну таблицу для каждого шаблона запроса", как упоминалось здесь, я настроил одну и ту же таблицу дважды, но с разными ключами для оптимизации времени чтения. -- This table supports queries that filter o…
28 фев '20 в 19:34
0 ответов

Попытка создать пространство ключей на кассандре с драйвером Python datastax

У меня есть эта странная ошибка, которую я не могу обойти, ошибка python - это то, что я не могу понять, неразрешимая точка контакта звучит как проблема с IP? cluster-ip отсутствует, когда я смотрю на клиента ниже NAME↑ TYPE CLUSTER-IP EXTERNAL-IP S…
05 апр '20 в 03:20
0 ответов

Ошибка запроса Cassandra COPY FROM с файлом CSV

Эта проблема: Я пытаюсь получить это, чтобы я мог использовать Cassandra для правильной работы с Python. Я использовал игрушечный набор данных, чтобы попрактиковаться в загрузке CSV-файла в Cassandra, но безуспешно. Кассандра работает нормально, ког…
1 ответ

Кассандра Астра безопасно развертывается на героку

Я разрабатываю приложение с использованием python и Cassandra(поставщик Astra) и пытаюсь развернуть его на Heroku. Проблема заключается в том, что подключение к базе данных требует, чтобы почтовый файл учетных данных присутствовал локально - https:/…
0 ответов

Проблема с подключением Python к Cassandra

Я пытаюсь получить данные из кластера Cassandra. Возникает проблема: когда-то извлекается несколько строк, а иногда нет.Я использую Python 3.8.5 и последнюю версию драйвера DataStax Python.Ниже приведен код from cassandra.cluster import Cluster from…
2 ответа

Как исправить проблему "Невозможно завершить операцию против любых хостов" в Кассандре?

У меня есть довольно простая функция AWS Lambda, в которой я подключаюсь к базе данных Amazon Keyspaces для Cassandra. Этот код на Python работает, но время от времени я получаю ошибку. Как мне исправить это странное поведение? У меня есть предполож…
1 ответ

Можно ли получить обратный вызов от Cassandra после операции INSERT, что запись была успешно создана?

Я столкнулся с очень странным поведением и пытаюсь понять, в каких случаях это может произойти. В моем приложении Python я получаю доступ к базе данных Cassandra через драйвер. Как вы можете видеть ниже, сначала я INSERTоперация, которая создает зап…