Я только что создал два кластера Cassandra через Docker. Команда docker exec -it name nodetool status
сообщает, что кластеры созданы, все в порядке:
Затем я попытаюсь ВСТАВИТЬ данные в таблицу из драйвера Python.
Вот мой код:
from cassandra.cluster import Cluster
from faker import Faker
import time
fake = Faker()
num = 0
cluster = Cluster(['172.17.0.2', '172.17.0.3'], port=9042)
session = cluster.connect()
session.execute('USE keys')
print("Start create data")
start = time.time()
for i in range(10000):
time.sleep(0.001)
num+=1
session.execute(
"""
INSERT INTO tt (id, title) VALUES (%(id)s, %(title)s)
""",
{'id': num, 'title': fake.address()}
)
end = time.time()
print("Total time: ", end - start)
И, наконец, когда я пытаюсь выполнить код, я выдал следующую ошибку в терминале: