给我找一个批量插入cassandra的代码例子
时间: 2024-05-07 12:24:01 浏览: 124
以下是一个简单的批量插入 Cassandra 的 Python 代码例子:
```python
from cassandra.cluster import Cluster
from cassandra.query import BatchStatement
cluster = Cluster(['127.0.0.1']) # 填写 Cassandra 的 IP 地址或主机名
session = cluster.connect('mykeyspace') # 填写要插入数据的 keyspace 名称
# 准备插入数据的语句
insert_stmt = session.prepare('INSERT INTO mytable (id, name, age) VALUES (?, ?, ?)')
# 创建批量插入语句对象
batch = BatchStatement()
# 添加要插入的数据到批量插入语句对象中
batch.add(insert_stmt, ('001', 'Alice', 23))
batch.add(insert_stmt, ('002', 'Bob', 25))
batch.add(insert_stmt, ('003', 'Charlie', 28))
# 执行批量插入操作
session.execute(batch)
# 关闭连接
cluster.shutdown()
```
以上代码会向名叫 `mytable` 的表中批量插入 3 条记录,每条记录包含一个 ID、一个名字和一个年龄。你可以根据自己的需求更改表名、表结构和要插入的数据。注意,在实际使用中,可能需要对批量插入的数据进行合理的分片和调度,以最大限度地提高插入性能。
阅读全文