芹菜事件参数捕获

Celery event args capturing

我想使用 celery 提供的任务事件来捕获任务参数。 我使用 redis 作为后端和代理(Pickle 作为序列化程序)。根据文档,可以通过监听 task-received 处理程序来获取此信息,其中将填充参数。

我面临的问题是,对于小数据输入,这按预期工作。当我使用大输入(二进制文件 - ~16MB)时,事件接收到的参数要小得多并被截断。

有人知道这是什么原因吗?感谢您的帮助!

Celery 对推送到事件的数据大小有限制。

可使用 repr_maxsize 配置。

我猜,但这可能会严重影响性能,应该避免。