了解celery worker节点
我使用
from celery import Celery
app = Celery('tasks', backend='amqp', broker='amqp://')
@app.task
def print_hello():
print 'hello there'
据我所知，celery将此任务转换为消息，并通过AMQP协议发送给代理（redis或rabbitmq）。然后将这些消息排队并传递给工作节点以处理该消息。
我的问题是,
-
null
共有1个答案
工作人员不仅需要Python，还需要您希望在其上运行的任务的所有代码。
但您没有专门处理节点,这正是为什么会有代理的原因。你把你的任务放到队列中，工人们来接他们。
我不知道你为什么在这里提到SOAP。这与任何事都无关。
-
问题内容： 因此，在昨天的工作中，我不得不编写一个应用程序来计算AFP文件中的页数。因此，我整理了我的MO：DCA规范PDF，找到了结构化字段及其3个字节的标识符。该应用程序需要在AIX机器上运行，所以我决定用Java编写它。 为了获得最大效率，我决定读取每个结构化字段的前6个字节，然后跳过该字段中的其余字节。这会让我： 因此，我检查字段类型，如果是，则增加页面计数器，如果不是，则不增加。然后，我
-
问题内容： 我经常卡在没有源的Java类文件中，并且试图理解我手头的问题。 请注意，反编译器是有用的，但在所有情况下都不足够… 我有两个问题 有哪些工具可用来查看Java字节码（最好从linux命令行中获得） 什么是熟悉Java字节码语法的良好参考 问题答案： 与其直接查看Java字节码（需要熟悉Java虚拟机及其操作），不如尝试使用Java反编译实用程序。反编译器将尝试从指定文件创建源文件。 该
-
如何获得Kafka单张唱片的大小？ 有一些关于我为什么需要这个的说明。 这似乎不是在ConsumerRecord或RecordMetadata类上公开的serializedValueSize。我并不真正理解这个属性的价值，因为它与对消费者有用的消息的大小不匹配。serializedValueSize用于什么？ 最大Poll.Records 在对poll（）的单个调用中返回的最大记录数。 这并不存在
-
本文向大家介绍深入了解JavaScript 防抖和节流，包括了深入了解JavaScript 防抖和节流的使用技巧和注意事项，需要的朋友参考一下 概述 说明 在项目过程中，经常会遇到一个按钮被多次点击并且多次调用对应处理函数的问题，而往往我们只需去调用一次处理函数即可。有时也会遇到需要在某一规则内有规律的去触发对应的处理函数，所以就需要使用到函数防抖与函数节流来帮助我们实现我们想要的结果以及避免不必
-
Query - Query就是把这种内部状态暴露给外部世界。查询被公开为由外部实体调用的异步回调。 异步回调是什么意思 Doc说，查询有两个限制1）。不应该改变工作流的状态2）。不会有任何阻塞操作。 但是我确实在查询方法中改变了变量，它正在改变值。 这仅仅是一种信念，即我们不应该在查询方法中编写可变或阻塞代码吗？ 我看不出查询和信号有什么区别。即使在工作流完成后，查询方法也会被调用，而as Sig
-
本文向大家介绍了解节点中代码执行的阻塞和解除阻塞，包括了了解节点中代码执行的阻塞和解除阻塞的使用技巧和注意事项，需要的朋友参考一下 现在，我们在fs模块中具有文件写入功能writeFileSync，如下所示- 同步表示已同步。这是一个阻塞代码示例。一旦文件写入完成，则仅对其余文件执行代码。上面的代码比较简单，但是如果我们进行大量的文件处理操作，将会导致应用性能下降。 这种代码执行方式将减慢其他请求