芹菜事件参数捕获
Celery event args capturing
我想使用 celery 提供的任务事件来捕获任务参数。
我使用 redis 作为后端和代理(Pickle 作为序列化程序)。根据文档,可以通过监听 task-received
处理程序来获取此信息,其中将填充参数。
我面临的问题是,对于小数据输入,这按预期工作。当我使用大输入(二进制文件 - ~16MB)时,事件接收到的参数要小得多并被截断。
有人知道这是什么原因吗?感谢您的帮助!
Celery 对推送到事件的数据大小有限制。
可使用 repr_maxsize 配置。
我猜,但这可能会严重影响性能,应该避免。
我想使用 celery 提供的任务事件来捕获任务参数。
我使用 redis 作为后端和代理(Pickle 作为序列化程序)。根据文档,可以通过监听 task-received
处理程序来获取此信息,其中将填充参数。
我面临的问题是,对于小数据输入,这按预期工作。当我使用大输入(二进制文件 - ~16MB)时,事件接收到的参数要小得多并被截断。
有人知道这是什么原因吗?感谢您的帮助!
Celery 对推送到事件的数据大小有限制。
可使用 repr_maxsize 配置。
我猜,但这可能会严重影响性能,应该避免。