使用Cassandra Python驱动查询AWS Keyspaces返回空列表的原因

尝试使用Prepared Statement通过Python的Cassandra驱动查询AWS Keyspaces，代码如下：

from cassandra.cluster import Cluster

cluster = Cluster(
    **conn_details
)
            
session = cluster.connect("mykeyspace")

query = ("SELECT timestamp "  
        "FROM mykeyspace.mytable "
        "WHERE t_id='123' "
        "AND p_id='321' "
        "AND timestamp IN ? "
        )

prepared_statement = session.prepare(query)

session.execute(prepared_statement, parameters=[ (1677145736507, 1677145728972) ]).current_rows

执行后返回空列表，但以下三种场景下执行IN查询能成功获取结果：

• 直接执行原生CQL查询字符串：

SELECT timestamp
FROM mykeyspace.mytable 
WHERE t_id='123'
AND p_id='321' 
AND collection_event_timestamp IN (1677145728972, 1677145736507) 

• 在AWS Keyspaces查询编辑器中执行该查询；
• 通过字符串格式化结合ValueSequence进行参数化查询：

id_tuples = (1677145736507, 1677145728972)

query = "SELECT timestamp FROM mykeyspace.mytable WHERE t_id='123' AND p_id='321' AND timestamp IN %s  "

session.execute(query, parameters=[ValueSequence(id_tuples)]).current_rows

请问Prepared Statement方式查询失效的原因是什么？

这是因为AWS Keyspaces对Cassandra原生Prepared Statement的支持存在局限性，尤其是处理IN子句的列表参数时：

• 参数解析逻辑不兼容：原生Cassandra驱动中，IN ?需要接收列表/集合类型参数，但AWS Keyspaces的查询引擎会把传入的元组当作单个复合值，而非多个独立查询条件值，导致查询条件不匹配，返回空结果。
• ValueSequence的工作机制：ValueSequence是驱动提供的特殊类型，执行时会直接将序列展开为IN子句中的多个独立值，本质是动态生成符合CQL语法的查询字符串，绕过了Keyspaces对Prepared Statement列表参数的解析限制。
• 托管服务的特性限制：AWS Keyspaces作为托管服务，并未完全实现原生Cassandra的所有Prepared Statement特性，IN子句的批量参数处理属于不兼容点，原生参数绑定方式无法被正确识别，而静态查询或ValueSequence的方式则符合Keyspaces的查询语法要求。

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