将值从 python 列表传递到 Cassandra 查询

Question

这里是初学者。 我有以下情况。

• 每行包含一个名称的文本文件。
• cassandra 3.5 数据库
• python 脚本

目的是让脚本一次从文件中读取一行（一个名称），并使用该名称查询 Cassandra。

仅供参考，除了我尝试将列表的值传递给查询时，一切正常。

我目前有类似的东西：

#... driver import, datetime imports done above
#...

with open(fname) as f:
content = f.readlines()

# Loop for each line from the number of lines in the name list file
# num_of_lines is already set
for x in range(num_of_lines):
    tagname = str(content[x])

    rows = session.execute("""SELECT * FROM tablename where name = %s and date = %s order by time desc limit 1""", (tagname, startDay))
    for row in rows:
        print row.name + ", " + str(row.date)

如果我删除 tagname 列表组件并使用名称值编辑查询本身，一切正常。

我在这里做错了什么？

Answer 1

简单地建立在上面@Vinny 的答案之上，格式只是替换了文字值。你需要在它周围加上引号。

for x in content:
    rows = session.execute("SELECT * FROM tablename where name ='{}' and date ='{}' order by time desc limit 1".format(x, startDay))
    for row in rows:
        print row.name + ", " + str(row.date)

Answer 2

你可以简单地遍历content：

for x in content:

    rows = session.execute("SELECT * FROM tablename where name = {} and date = {} order by time desc limit 1".format(x, startDay))
    for row in rows:
        print row.name + ", " + str(row.date)
    ....

此外，您不需要为字符串添加 3 个引号。单引号就足够了（3个引号用于文档/python中的多行cmets）

请注意，这可能会以不同的错误结束；但是您将在行上进行迭代，而不是在索引上进行迭代并读取行。