使用芹菜时，cassandrapython驱动程序阻塞

Question

我使用Celery任务来读/写Cassandra节点/集群。为此，我使用了cassandra驱动程序python包。在

每次我运行芹菜，任务写（插入…），不要动，因为我假设连接阻塞了。我尝试过使用execute\u concurrent运行，但没有产生任何结果。在

有什么建议吗？在

Answer 1

确保您正在工作进程中创建集群和会话后分叉。This doc显示了一个示例。它使用cquengine对象映射器，但是fork之后初始化的机制同样适用于核心驱动程序。This FAQ在服务框架的上下文中也提到了这个问题。在