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

Клиентская библиотека Python для Apache Cassandra
2 ответа

Как реализовать разбиение на маркеры с помощью Python-драйвера Cassandra?

Да, перебрать Query это хорошо, но мне нужны результаты подкачки и отправить их с токеном на веб-интерфейс. Могу ли я создать токен для предыдущей страницы? Как я могу получить и использовать ResponseFuture._paging_state в моделях или Querysets. Я и…
1 ответ

Как получить последний вставленный идентификатор в Python Cassandra?

Я использую драйвер Python Cassandra, я искал, как получить последний вставленный идентификатор, но не смог найти никакого решения, кроме этого, но я хочу получить UUID или идентификатор не отметку времени Может ли тело помочь мне, пожалуйста?
07 ноя '17 в 10:10
0 ответов

Ошибка при обновлении таблицы cassandra через скрипт python

Я пытаюсь обновить таблицу Cassandra с помощью приведенного ниже сценария. import requests import json import os from cassandra import ConsistencyLevel from cassandra.cluster import Cluster from cassandra.query import SimpleStatement from cassandra.…
12 фев '19 в 11:10
0 ответов

Как написать SortedSet типа данных Кассандра как JSON в Python?

Я пытаюсь сбросить данные Кассандры в формате CSV, используя Python. Пока что я разработал следующий скрипт: from cassandra.cluster import Cluster from cassandra.auth import PlainTextAuthProvider from cassandra.query import tuple_factory from cassan…
13 сен '17 в 19:42
1 ответ

Кассандра: Удалить данные, не удаляя структуру таблицы

Я провожу некоторые тесты на Кассандре, для которых необходимо удалять данные в таблице после каждого запуска. Поэтому я написал скрипт, который ОБРАБАТЫВАЕТ данные. Мой вопрос, это оставляет таблицу ненастроенной (удаляет все столбцы) после того, к…
1 ответ

Записать данные в cassandra с помощью анализатора Python

У меня есть пользовательская библиотека Python, которая анализирует данные из файла и возвращает пары ключ-значение. Теперь, как мне использовать эту библиотеку для вставки данных в семейство столбцов Cassandra? Я использую драйвер Python Cassandra.
1 ответ

Соединение Кассандры на холостом ходу и тайм-аут

Я пытаюсь загрузить и удалить данные из Cassandra с помощью драйвера python. Я пробовал это как с использованием cassandra, запущенного в док-контейнере, так и локально после того, как версия докера доставляла мне проблемы. Вот пример того, что я де…
28 фев '17 в 16:59
3 ответа

Регистрация всех запросов с помощью cassandra-python-driver

Я пытаюсь найти способ протоколировать все запросы, сделанные на Cassandra из кода Python. В частности, ведение журнала, как они закончили выполнять с использованием BatchStatement Есть ли какие-либо хуки или обратные вызовы, которые я могу использо…
16 окт '17 в 15:12
0 ответов

Ошибка записи тайм-аута в Cassandra с использованием драйвера Python Cassandra

У меня есть кластер с одним узлом, и когда я выполняю следующий запрос, я получаю следующую ошибку, DELETE FROM issuetable WHERE "partitionId"='1'; ** Ошибка: **: WriteTimeout: Error from server: code=1100 [Coordinator node timed out waiting for rep…
1 ответ

Схема не полностью переведена из протокола Thrift в протокол CQL

Я пытаюсь перейти от использования pycassa к нативному протоколу в моем проекте (что позволит нам обновить версию cassandra). Моя схема была определена с использованием pycassa, поэтому она создала семейство Column с использованием компактного храни…
1 ответ

Python Cassandra: запрос аутентификации не был отправлен, это подозрительно, потому что драйвер ожидает аутентификацию

Я пытаюсь подключиться cassandraDB используя питон. Я использовал аутентификацию как PlainTextAuthProvider, Это мой фрагмент кода. auth_provider = PlainTextAuthProvider(username="foo", password="bar") cluster = Cluster([1.1.1.1], protocol_version=2,…
1 ответ

Драйвер питона Cassandra - заморожен с помощью Object Mapper

Я пытаюсь объявить и создать (используя sync_tableТаблица Cassandra с использованием Object Mapper из драйвера Python Cassandra (cassandra-driver версия пакета 3.14), но я не могу найти способ определить замороженное значение в коллекции. Есть ли сп…
1 ответ

Как сделать перенос портов при использовании карты трансляции адресов с cassandra?

Я пытаюсь подключиться к кластеру scylladb при компоновке с использованием карты трансляции адресов. Я могу заставить код работать, только если я жестко закодирую порт при создании экземпляра Cluster: from cassandra.cluster import Cluster from cassa…
1 ответ

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

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

Помимо установки драйвера cassandra, какое другое возможное решение, потому что установка драйвера решает проблему

Код: from cassandra.cluster import Cluster,SimpleStatement cluster = Cluster(['192.168.2.1']) session = cluster.connect() Ошибка: ImportError: No module named 'cassandra'
20 ноя '18 в 05:24
1 ответ

Кассандра несколько подключений сохраняет, не работает [Python]

У меня есть 2 кластера кассандры, мой простой скрипт пытается читать из одного и писать в другой. Согласно документации, у меня есть registered_connection (названный) ко 2-му кластеру и подключение по умолчанию к 1-му кластеру. Я могу запросить разл…
02 ноя '17 в 16:26
1 ответ

CQL - нереальная альтернатива на входе '12345' (СОЗДАЙТЕ ТАБЛИЦУ, ЕСЛИ НЕ СУЩЕСТВУЕТ [12345]...)">

Я создаю таблицу Кассандры, если таблица не существует с кодом Python ниже: cluster = cassandra_cluster.Cluster([settings.CASSANDRA_CONTACT_POINT], settings.CASSANDRA_PORT) session = cluster.connect(settings.CASSANDRA_KEYSPACE) session.execute("CREA…
1 ответ

Как использовать подготовленное утверждение о материализованном представлении в драйвере Python Cassandra?

Я использую базу данных Scylla и драйвер Python Cassandra для своего проекта, я использовал подготовленный оператор для каждого запроса, и он работает, но когда я использую подготовленный оператор для материализованного представления, он мне ничего …
26 дек '17 в 14:02
0 ответов

run_add_or_renew_pool трассировка в драйвере Cassandra Python, когда один хост не работает

Один из хозяев кластера Кассандра упал. В этом часовом окне эти журналы отслеживания добавляются в журналы приложений. Пространство ключей RF и уровень согласованности настроены таким образом, что мы можем справиться с потерей одного узла. В чем при…
19 июн '18 в 07:19
1 ответ

Вставьте информационный кадр Pandas в таблицу Cassandra

Из документации есть способ вставить данные в таблицу: session.execute( """ INSERT INTO users (name, credits, user_id) VALUES (%s, %s, %s) """, ("John O'Reilly", 42, uuid.uuid1()) ) Имя столбца должно быть указано там. Однако, в моем случае, у меня …