使用python将值存储到cassandra中

pip install cassandra-driver

from cassandra.cluster import Cluster

cluster = Cluster(['cassandra-host1', 'cassandra-host2'])  # 替换为实际的Cassandra主机地址
session = cluster.connect()

session.execute("""
    CREATE KEYSPACE IF NOT EXISTS my_keyspace 
    WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '3'}
    """)

session.execute("""
    CREATE TABLE IF NOT EXISTS my_keyspace.my_table (
        id UUID PRIMARY KEY,
        value text
    )
    """)

from cassandra.query import SimpleStatement

insert_statement = session.prepare("""
    INSERT INTO my_keyspace.my_table (id, value) VALUES (?, ?)
    """)

values = [
    ('11111111-1111-1111-1111-111111111111', 'Value 1'),
    ('22222222-2222-2222-2222-222222222222', 'Value 2')
]

for value in values:
    session.execute(insert_statement, value)

session.shutdown()
cluster.shutdown()