Here's an example of how to connect to Amazon Keyspaces using the Cassandra driver in Python:
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
auth_provider = PlainTextAuthProvider(username='your_service_user_name', password='your_service_password')
cluster = Cluster(['your_keyspaces_endpoint'], auth_provider=auth_provider)
session = cluster.connect()
# Create a keyspace
session.execute("""
CREATE KEYSPACE IF NOT EXISTS my_keyspace
WITH REPLICATION = { 'class': 'SimpleStrategy', 'replication_factor': 3 }
""")
# Create a table
session.execute("""
CREATE TABLE IF NOT EXISTS my_keyspace.my_table (
id UUID PRIMARY KEY,
name text,
age int
)
""")
# Insert data
session.execute("""
INSERT INTO my_keyspace.my_table (id, name, age)
VALUES (uuid(), 'Alice', 30)
""")
# Query data
rows = session.execute('SELECT name, age FROM my_keyspace.my_table')
for row in rows:
print(row.name, row.age)
