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 获取了值列_a。

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

如有任何回应，我们将不胜感激。

Answer 1

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

import uwsgi

def myconnect(...):

global_connection = ...

uwsgi.post_fork_hook = myconnect