python - 将 pycassa 与 uwsgi 一起使用时的问题

Question

我们将 pycassa 与 uwsgi 一起使用。大约有 16 个 uwsgi 进程。

奇怪的是，一个进程可以得到另一个进程查询的数据。例如，列族 A 中有一行，如下所示：

{row_key, {'column_a': 1, 'column_b': 2}}

进程 1 运行：get(row_key, columns=['column_a', ])

进程 2 运行：get(row_key, columns=['column_b', ])

但是，有时，进程 1 得到 column_b 的值，进程 2 得到 column_a 的值。

这是连接池的已知问题吗？

任何回应表示赞赏。

Answer 1

使用 uwsgi.post_fork_hook api 函数为每个工作人员打开一个连接

import uwsgi

def myconnect(...):

global_connection = ...

uwsgi.post_fork_hook = myconnect