Cassandra python驱动程序在使用Celery时被阻止

Question

我正在使用 Celery 任务来读取/写入 Cassandra 节点/集群。为此，我使用的是 cassandra-driver python 包。

每次我运行 Celery 时，写入（插入 ... ）的任务都会冻结，因为我假设连接正在阻塞。我试图用execute_concurrent运行，但这并没有导致任何结果。

有什么建议吗？

Answer 1

确保在工作进程中创建集群和会话后分叉。本文档显示了一个示例。它使用 cqlengine 对象映射器，但在分叉后初始化的机制同样适用于核心驱动程序。本常见问题解答还提到了服务框架背景下的问题。