celery get 和 join 之间的区别

之间有什么区别：

 r = group(some_task.s(i) for i in range(10)).apply_async()
 result = r.join()

And:

 r = group(some_task.s(i) for i in range(10))()
 result = r.get()

Celery 文档使用了这两个示例，我没有看到任何区别。

简短回答

虽然get and join的方法group应该返回相同的结果，get实现一些缓存，并且可能会更有效，具体取决于您使用的后端。除非你确实需要使用join对于某些边缘情况，您应该使用get.

长答案

这是get芹菜的做法ResultSet类其中GroupResult阶级延伸。

def get(self, timeout=None, propagate=True, interval=0.5,
        callback=None, no_ack=True, on_message=None):
    """See :meth:`join`
    This is here for API compatibility with :class:`AsyncResult`,
    in addition it uses :meth:`join_native` if available for the
    current result backend.
    """
    if self._cache is not None:
        return self._cache
    return (self.join_native if self.supports_native_join else self.join)(
        timeout=timeout, propagate=propagate,
        interval=interval, callback=callback, no_ack=no_ack,
        on_message=on_message,
    )

我们看到的第一件事是文档字符串告诉我们查看join记录方法。这立即表明这些方法非常相似。

看着对方的身体get方法中，我们可以看到它首先检查缓存的值，如果已设置则返回该值。如果没有找到缓存值，get将调用join or the join_native方法取决于后端是否支持本机连接。如果你找到它的格式return声明有点令人困惑，这本质上是同一件事：

if self.supports_native_join:
    return self.join_native(timeout=timeout,
                            propagate=propagate,
                            interval=interval,
                            callback=callback,
                            no_ack=no_ack,
                            on_message=on_message)
else:
    return self.join(timeout=timeout,
                     propagate=propagate,
                     interval=interval,
                     callback=callback,
                     no_ack=no_ack,
                     on_message=on_message)

的文档字符串join方法有这个说法。

对于结果存储后端来说，这可能是一项昂贵的操作，必须 诉诸轮询（例如数据库）。你应该考虑使用join_native如果你的后端支持的话。

So you should正在打电话join_native代替join如果你的后端支持的话。但为什么要费尽心思有条件地调用其中一个呢？get为您总结了这个逻辑吗？只需使用get反而。