Python 在线程中获取/发布数据

Question

我已经实现了Python代码，它正在监听我的数据库并连续将数据存储在pandas DataFrame中(插入新行并更新旧行作为无限循环)。数据传入 python 时与数据库中的显示方式相同(平均每 1-5 秒更新一次)。

我的Python代码的第二部分应该用这个DataFrame做一些事情。所以我想做的就是将我的代码分成单独的线程。

第一个线程将数据存储在 DataFrame 中，另一个线程(或多个线程)将使用 DataFrame 做一些事情并通过绘图、变量等返回结果。

我已经对线程进行了一些研究，但还没有找到解决方案。非常感谢有关此问题和/或示例代码的任何帮助。

Answer 1

毕竟，我在数据库中创建了一个表，该表通过触发器函数功能不断更新。在Python方面，我已经完成了异步调用该表、获取数据并完成其工作的线程。

也许，这不是理想的解决方案，但它有效并满足了我当前的需求。