1

我有几个 python 脚本负责管理一些实时提要处理。它的结构如下:

脚本 1:管理实时事件的“聚合”列表,提供有关所有事件的一些非常薄的数据。

脚本 2:管理处理每个实时事件的详细提要的线程列表。

脚本 1 负责定义哪些事件是活动的,并且(现在)将活动事件的所有唯一标识符写入一个平面文件(根本不喜欢那个)。脚本 2 读取这些唯一标识符,检查它是否已经有一个具有该 ID 的线程,如果没有,它启动该线程,然后处理该事件的详细数据。脚本 2 没有定义该线程何时应标记为非活动或从准队列文件中删除。线程知道它们何时应该终止自己,并且脚本 1 监视作为主列表的提要,该主列表定义了哪些事件处于活动状态。这工作但相当好,但对我来说感觉很笨拙和贫穷。

我看过这个类似于多处理池的线程池?和像这样的队列方法https://www.ibm.com/developerworks/aix/library/au-threadingpython/但它们似乎不太适用,因为实时事件线程没有指定的寿命......他们生成并一直存在,直到它们的事件结束(以小时为单位)。

我对 python 还是很陌生,这让我觉得有点过头了。您可以在实施方法方面提供的任何类型的健全性/愚蠢性检查将不胜感激。

编辑:由于系统管理员限制,我无法使用外部模块:(

4

1 回答 1

1

听起来您需要使用类似celery.

于 2013-10-18T16:30:09.997 回答