运行Cassandra表间数据迁移脚本时发生错误求助

看起来你在运行Python脚本把source keyspace里的results表数据（筛选name = 'Joan'的记录）复制到destination keyspace的同表时遇到了问题。先把你提供的脚本贴出来方便参考：

#!/usr/bin/env python2.7
import pika
import json, os
import magic
import time
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
from cassandra import query
from sets import Set

keyspace_from = 'source'
keyspace_to = 'destination'
table = 'results'
selection = "name = 'Joan'"
cluster_ips = ['10.0.44.21', '10.0.44.22', '10.0.44.23']
username = 'cassandra'
password = '...'

我帮你梳理几个最可能导致错误的点，以及对应的修复方案：

一、核心复制逻辑缺失（最常见原因） #

你当前的脚本只定义了连接参数和筛选条件，但完全没有实现从源表查询数据和插入目标表的核心代码！这肯定会运行出错或者没有任何效果。补充这部分逻辑：

# 补充：建立Cassandra连接并获取会话
auth_provider = PlainTextAuthProvider(username=username, password=password)
# 可选：添加数据中心感知的负载均衡策略，适配多DC集群
from cassandra.policies import DCAwareRoundRobinPolicy
cluster = Cluster(
    cluster_ips, 
    auth_provider=auth_provider,
    load_balancing_policy=DCAwareRoundRobinPolicy(local_dc='你的数据中心名称')
)
session = cluster.connect()

# 1. 查询源表的目标数据
# 注意：如果name不是主键/聚类键，需要添加ALLOW FILTERING（生产环境不推荐，建议建索引或物化视图）
source_cql = f"SELECT * FROM {keyspace_from}.{table} WHERE {selection}"
# 用prepare提升查询性能
prepared_source_query = session.prepare(source_cql)
rows = session.execute(prepared_source_query)

# 2. 将数据插入目标表（前提是目标表结构和源表完全一致）
# 使用JSON插入简化字段映射
insert_cql = f"INSERT INTO {keyspace_to}.{table} JSON ?"
prepared_insert_query = session.prepare(insert_cql)

for row in rows:
    # 将Cassandra行对象转为字典再转成JSON字符串
    row_dict = row._asdict()
    row_json = json.dumps(row_dict)
    session.execute(prepared_insert_query, (row_json,))
    # 可选：添加微小延迟，避免短时间内给集群造成过大压力
    time.sleep(0.01)

# 最后关闭连接释放资源
cluster.shutdown()

二、连接与认证问题 #

• 确认username和password的正确性，并且该用户拥有source和destination两个keyspace的SELECT和INSERT权限
• 检查cluster_ips里的节点是否都能正常访问，没有防火墙拦截或网络不通的情况
• 如果是多数据中心集群，一定要指定正确的local_dc，否则连接会很慢甚至失败

三、查询条件的合法性问题 #

• 如果name不是表的主键、聚类键，也没有创建二级索引，直接执行WHERE name = 'Joan'会报错！此时要么添加ALLOW FILTERING（仅测试用），要么给name创建二级索引，或者生产环境推荐使用物化视图来优化查询
• 确保selection的语法正确，字符串引号不要混用（你这里用的单引号是对的）

四、依赖版本兼容问题 #

你用的是Python2.7，注意：

• cassandra-driver要安装支持Python2的版本，推荐cassandra-driver==3.25.0（这是最后支持Python2的稳定版本）
• 检查magic、pika等依赖是否正确安装，避免导入错误

内容的提问来源于stack exchange，提问作者Mnemosyne