CQLSH 复制错误类型错误："INT"对象不可迭代

Question

我有下面的代码试图转储表数据，但下面的错误是TypeError:'int'对象不可迭代。

import argparse
import sys
import itertools
import codecs
import uuid
import os
try:
import cassandra
import cassandra.concurrent
except ImportError:
sys.exit('Python Cassandra driver not installed. You might try "pip install cassandra-driver".')
from cassandra.cluster import Cluster, ResultSet
from cassandra.policies import DCAwareRoundRobinPolicy
from cassandra.auth import PlainTextAuthProvider
from cassandra.cluster import ConsistencyLevel
datafile = "/Users/username/adf.csv"
if os.path.exists(datafile):
os.remove(datafile)
def dumptableascsv():
auth_provider = PlainTextAuthProvider(username='cassandra', password='cassandra')
cluster = Cluster(['127.0.0.1'],
load_balancing_policy=DCAwareRoundRobinPolicy(local_dc='Cassandra'),
port=9042, auth_provider=auth_provider)
session = cluster.connect('qualys_ioc')
session.execute("COPY qualys_ioc.agent_delta_fragment(agent_id , delta_id , fragment_id, boolean ,created_on)  TO "
"'/Users/username/adf.csv' WITH HEADER = true ;", ConsistencyLevel.QUORUM)
dumptableascsv()

Answer 1

COPY是cqlsh推荐——它不是CQL的一部分，不能通过本机协议客户端执行。由于您在Session.execute的parameters位置传递了一致性级别，因此您得到的是此特定错误，而不是服务器请求错误。

您可以使用cqlsh从脚本中执行此操作，或者查看用于高性能加载和卸载的DS Bulk工具。