小编Yan*_* HG的帖子

我有一个大循环来生成任务：

for i in range(1000):
    receiver.apply_async(args=(i), kwargs={}, exchange=topic_exchange, routing_key=topic_key)

celery.contrib.batches我发现在 celery 3.X 之前或celery_batchescelery 4.X 之后有一个模块。但这个模块似乎不支持这样的参数。那么我该怎么做呢？

我正在使用 celery 4.4.7 和rabbitmq。