Cassandra python驅動程序在使用Celery時被阻塞

Question

我正在使用Celery任務來讀取/寫入Cassandra節點/羣集。爲此，我使用cassandra-driver python包。

每次我運行Celery時，寫入（INSERT INTO ...）的任務，凍結，因爲我假設連接被阻塞。我試着用execute_concurrent運行，但沒有導致任何結果。

有什麼建議嗎？

Answer 1

確保您在工作進程中創建了Cluster和Session post分支。 This doc顯示了一個例子。它使用cqlengine對象映射器，但fork之後的初始化機制同樣適用於核心驅動程序。 This FAQ也在服務框架中提到了這個問題。