任务工人进入冻结状态，再也不会回来
是指在分布式系统中，任务工人（Worker）在完成任务后进入冻结状态，不再参与后续的任务处理。这种状态通常是由于任务工人的工作负载已经达到上限或者系统需要进行维护等原因导致的。
在云计算领域，任务工人的冻结状态可以通过自动伸缩技术来实现。自动伸缩是一种根据系统负载情况自动调整资源规模的技术，可以根据任务工人的工作负载情况来动态调整任务工人的数量，以保证系统的高效运行。
任务工人进入冻结状态后，系统可以根据需要进行以下操作：
- 任务重分配：当任务工人进入冻结状态后，系统可以将其分配给其他可用的任务工人，以确保任务的及时完成。
- 资源回收：当任务工人进入冻结状态后，系统可以回收其所占用的资源，以便其他任务工人可以使用这些资源。
- 系统维护：当任务工人进入冻结状态后，系统可以利用这段时间进行系统维护工作，例如更新软件、修复漏洞等。
任务工人进入冻结状态的优势包括：
- 资源利用率提高：通过自动伸缩技术，可以根据任务工人的工作负载情况动态调整资源规模，从而提高资源的利用率。
- 系统可靠性提高：当任务工人进入冻结状态后，系统可以通过任务重分配等方式来保证任务的及时完成，从而提高系统的可靠性。
- 系统维护便捷：任务工人进入冻结状态时，系统可以利用这段时间进行系统维护工作，例如更新软件、修复漏洞等，从而提高系统的稳定性和安全性。
任务工人进入冻结状态适用于以下场景：
- 高负载情况：当系统的工作负载达到上限时，可以将一部分任务工人进入冻结状态，以避免系统过载。
- 系统维护：当系统需要进行维护时，可以将任务工人进入冻结状态，以便进行系统更新、修复漏洞等工作。
- 资源调整：当系统需要调整资源规模时，可以通过任务工人进入冻结状态来释放或分配资源。
腾讯云相关产品和产品介绍链接地址：
- 自动伸缩相关产品：腾讯云弹性伸缩（https://cloud.tencent.com/product/as）
- 任务调度相关产品：腾讯云批量计算（https://cloud.tencent.com/product/bc）
- 云计算基础设施相关产品：腾讯云云服务器（https://cloud.tencent.com/product/cvm）
- 云计算存储相关产品：腾讯云对象存储（https://cloud.tencent.com/product/cos）
- 云计算网络相关产品：腾讯云私有网络（https://cloud.tencent.com/product/vpc）
- 云计算安全相关产品：腾讯云云安全中心（https://cloud.tencent.com/product/ssc）
请注意，以上链接仅供参考，具体产品选择应根据实际需求进行评估和决策。
相关·内容
我在分布式模式下运行CP3.2，甚至使用"tasks.max"："1“有任务”未分配“状态也定义了一些连接器。我增加了分配给工人的内存，重新启动了工人，解决了我的问题，或者增加了一个工人解决了这个问题。
如果"tasks.max“>1有一些任务处于”未分配“状态，但如果我只定义了一个任务，则它应该处于”运行“状态。
但是，我需要了解在什么情况下，任务会进入“未分配”状态，以及如何解决这个问题(使其运行)。
致以敬意，
[医]花生
浏览 4提问于2017-04-14得票数 4
2回答
我使用的是 + RabbitMQ。
当芹菜工人不可用时，所有任务都在RabbitMQ中等待。
就像它在线一样，所有这些任务都会立即执行。
我能以某种方式阻止它的发生吗？
例如，有100个(相同的)任务在等待芹菜工人，当芹菜工人上线时，我可以只执行其中的一个吗？
浏览 1提问于2014-10-25得票数 0
4回答
我使用RabbitMQ作为我的消息代理，我的工人是芹菜任务。我正在尝试诊断一个问题，即我正在将任务排队到RabbitMQ，但芹菜没有接上然后接上。
有没有一种方法可以检查哪些任务在RabbitMQ中排队？我想知道它们进入队列的日期和时间、指定的任何ETA、参数和任务名称。
我在文档中找不到这些信息--可能是我忽略了它--希望你们中的一些人可能知道一种简单的方法来检查任务队列。谢谢。
浏览 0提问于2012-10-24得票数 9
回答已采纳
我正在开发一个应用程序，该应用程序从facebook获取图像。我正在使用核心数据来保存图像。我使用dispatch_asyc函数将图像保存在核心数据中。我使用
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_BACKGROUND, 0)
保存图像，这样我的主线程就不会阻塞。
但有时我观察到应用程序冻结，没有响应。此外，如果用户进入任何图像的全屏，它将开始以相同的方式获取评论、点赞和保存。
如果我使用私有队列并使用相同的队列进行保存，那么应用程序就不会冻结。
由于我在应用程序中的许多地方使用全局队列，这是应用程序冻
浏览 0提问于2013-05-04得票数 0
回答已采纳
2回答
我想把execve进程的退出状态0发送给启动它的进程。因为一旦成功，execve就再也不会回来了，所以在那之后我就不能做任何事情了。但我想知道execve是否运行成功。
提前感谢
浏览 10提问于2013-03-19得票数 5
1回答
给予：
任务以aaaBBBccc格式进入队列(其中字母是访问自己的任务，在同类任务、资源之间共享的任务)。工人要执行的任务不止一个，但远远少于任务的数量。从大量工人手中超载共享资源是不可取的。理想的解决方案是一次执行不同的任务，而且永远不会相同。我在这里看到的最佳解决方案是从队列中得到一个随机任务，从而减少共享相同资源的机会。
问题：
是否有办法控制工人的任务消耗？或者创建一个定制的芹菜后端，其中SET用于存储任务而不是列表？
浏览 1提问于2014-09-16得票数 1
有一个任务分配给工人A，但是花了一段时间后，工人A意识到，这不能由自己处理，需要转移到工人B。
我们如何使用Twilio任务路由器来实现这一点？
浏览 1提问于2021-06-22得票数 0
回答已采纳
1回答
我想知道什么是正反两方面，当你试图用android打开一个新的活动，并通过调用finish立即销毁前一个活动。
人们认为这是个坏主意，因为Android可以在内存占用过多的情况下处理活动并删除它们，但是如果我一次进入该活动，用户可能再也不会回来了，那又如何呢？这是个糟糕的选择吗？
另外，通过完成活动，后退按钮的历史记录是“清楚的”，因此它不会返回到该活动(只有当您的用户流需要返回时，我认为您不应该调用finish )。
在内存方面，最好是用finish杀死活动，或者离开android，让这个活动在后台进行，因为谁知道这个活动有多长时间？
我觉得，您可以帮助系统GC您关闭的活动，并确保用户在退出
浏览 5提问于2015-04-27得票数 0
回答已采纳
这是我的unityScript代码，它有一个简单的coroutine循环。此代码与编辑器测试非常好，但在移动电话和实时测试，如果你想要进入主菜单，并再次回来进行计数的计数器冻结。换句话说，您从级别1=>2开始(每件事情都运行得非常好)之后，2=>1，当您再次进入2级时，倒计时将冻结在第一个数字！！
function Start () {
StartCoroutine("DoSomething");
}
-
function DoSomething () {
for (var i = 5; i >= 0; --i) {
pr
浏览 6提问于2015-05-13得票数 0
回答已采纳
我正在开发一个高性能的应用程序，它会导致主进程似乎停止响应和崩溃--不时地由于过载(我得到了“关闭应用程序对话框”，所以应用程序本身永远不会退出，只是结冰，这很烦人)
我欢迎任何简洁的方法来语法地检测应用程序被冻结的时间，所以我可以使用BAT (或其他方法)自动终止进程并重新启动。
当然，这是对应用程序进行审计时的临时修复，但同时它也非常有用。
TieBreaker : BTW，有没有办法覆盖windows的异常屏幕，然后退出应用程序？这在大多数情况下都是令人讨厌的特性。
编辑:
看在上帝的份上：的应用程序快冻死了，尽管每个任务都运行在BG工人和线程中！我在评论中详细说明了这一点。得了吧，我没
浏览 10提问于2012-01-03得票数 7
2回答
我有芹菜任务，100输入数据在队列中，需要执行使用5名工人。
如何获得哪个工作人员正在执行哪个输入？
每个工人执行多少输入和它的状态？
如果任何任务失败，如何单独获得失败的输入数据并与可用的工作人员一起重新执行？
是否有任何可能的方法来定制芹菜根据工人的具体情况。
我们可以把芹菜工人限制和花结合起来。
我没有使用任何框架。
浏览 3提问于2016-01-12得票数 3
1回答
当前，我有一个Ec2实例来阻止API请求。
用户订单通过芹菜任务进入红葡萄酒队列。
我有两个Ec2实例处理队列
问题是，API和芹菜工人的代码库是相同的。因为e，g
我使用cutsomer.process_order(order_id)
然后工人来做剩下的事。
有没有办法将API从工作代码中分离出来。我想在单独的代码库中创建API，在单独的代码库中生成工作人员。
浏览 2提问于2016-05-02得票数 5
回答已采纳
1回答
平稳地将轨道物体移回轨道
、、、
我有一个物体围绕玩家的精灵运行，代码如下所示：
x = player.x + sin(_float) * _radius;
y = player.y + cos(_float) * _radius;
_float += 0.01;
一个事件可以触发物体飞离玩家去追逐目标。当它击中目标后，我想让这个物体滑回玩家的身边，顺利地回到环绕玩家的轨道上。
到目前为止，我尝试过的每一件事都会使它突然或完全飞到一个位置，再也不会回来了。
编辑:我最终得到了一个将物体速度设置到sin/cos轨道上的解决方案，而不是直接设置x和y坐标。谢谢你的想法！
浏览 0提问于2017-12-31得票数 3
回答已采纳
1回答
我有一个带有Rails和的简单堆栈。我以一种正常的方式排队工作，我有一群工人在执行任务。没什么疯狂的。
我的问题是，如果我让工人长时间地工作，他们就会停止在应用程序的模型上具有可见性，而对这种方法的每次调用都会导致undefined_method。
这是非常奇怪的，因为可以完美地工作几天，然后突然开始失败。重新启动工人可以解决问题，但通常会在一段时间后回来。
我不知道会发生什么，所以任何指点都是非常感谢的。
浏览 1提问于2011-12-06得票数 2
回答已采纳
最近我遇到了Android studio的问题，在全屏模式下，当插件或设置窗口打开或任何其他弹出窗口时，如果我与桌面交换，然后再回来，Android studio将冻结并且没有弹出窗口显示，直到我进入Esc关闭它们或强制退出，有什么解决方案吗？
浏览 2提问于2016-02-08得票数 6
只有一个阻塞队列。有一个相同的工作人员池，当某个东西被推到队列中时，它只是简单地等待条件变量，然后尝试从队列中弹出。假设队列包含任务。
在理想的情况下，线程将一致地弹出任务。我想在这个概率上加上一些偏差，这样每个员工都会根据任务的优先级，弹出一定百分比的任务。但是，如果队列中有未处理的任务，则不应有意空闲线程。
微不足道的例子。
这里有3个工人，111个任务，每秒有一个任务进入队列。每项任务大约需要1秒的时间来处理。工人们的工作重点是10，1,100。然后，工人应该弹出大约10，1和100项任务。
是否有一种使用标准条件变量和互斥变量来实现这种机制的方便方法？--概率方法很好。
浏览 1提问于2014-03-26得票数 3
我有一个包含65k+条目的数据库，它在我的生产Rails应用程序中使用，我想从我的CSV文件中添加一些40k+更多的行，以确保数据进入: 1)我的开发机器上的db，2)生产服务器上的db，3)我团队成员机器上的db。
我应该选择什么方法？一个用于填充表的rake任务？迁移？
我做错了什么吗？
浏览 0提问于2012-01-10得票数 0
回答已采纳
1回答
我有一份清单：
url_list=["abc.com","def.com","xyz.com"."pqr.com"...] - 100,000 entries
我想用100名芹菜工人来浏览这个列表，以减少做这件事所需的时间。
我的问题是:我如何向工人提供这个url_list，以便这100名芹菜工人一次在url_list上射击，而不触及已经被其他工人遍历过的列表元素？
我创建了一个目录，proj-> celery.py，tasks.py
正如我所理解的，我将在tasks.py文件中提到我的任务，并在python中使用.del
浏览 2提问于2014-08-06得票数 0
我有服务器状态页面设置，可以通过http://localhost/server-status和apache2ctl status之类的命令访问它。
是否有一种方法可以访问服务器状态页面中的信息或生成信息(可能使用mod_perl)，而不必使用apache工作人员？
当apache2被冻结时，这将特别有用，例如在很长一段时间内没有工人可用。
浏览 0提问于2020-01-23得票数 3
我使用yo webapp创建了一个项目(显然安装了generator-webapp )。一切都很好，但我还是遗漏了一些东西。我相信这是一个如此简单的答案，我再也不会回来了，因为我会觉得太尴尬了。
我想使用指南针，这是从盒子里出来的约曼，但我不知道怎么做。我的意思是，任何Sass文件中的@import "compass...etc"显然都不能工作，因为在app/bower_components ( Sass @import在Gruntfile.js中指定的默认路径)中没有compass目录。
现在我应该怎么做才能导入Compass样式表？
浏览 7提问于2013-07-31得票数 0
回答已采纳
我正在使用ROUTER-to-DEALER设计，在中间进行一些处理，主要是对数据进行非序列化处理。但有时我需要在backend中重新发送一个有效负载，以便发送到一个Worker目的地。
重新发送一个有效载荷是容易的，但我需要重新发送给一个新的工人(一个免费的或至少不是同一工人)。
我注意到*_multipart函数包含三个字段，第一个字段是地址(对于一个工作人员？)。
问：有办法找到免费员工的地址吗？
浏览 3提问于2017-08-06得票数 1
我正在使用芹菜，rabbitmq的项目工作。我想有权控制间隔队列推送任务给工人(Celeryd)。
浏览 2提问于2011-10-17得票数 0
1回答
如果我有一个移动web应用程序(带有元标签name="apple-mobile-web-app-capable" content="yes"的网站)，并将其保存到主屏幕以创建“应用程序”……然后打开应用程序，使用四指轻扫切换应用程序并切换回移动web应用程序……它会带我回来，但这个应用程序完全被锁定/冻结/禁用。
有没有办法让应用程序在滑动离开并返回时不会被锁定？如果没有，我想重启应用程序比打开一个冻结的屏幕更好。那么这是可能的吗？
浏览 3提问于2012-02-02得票数 2
我正在评估IoT样式应用程序的Service Fabric，使用的模型是每个设备都有自己的参与者，以及系统中的其他参与者。我知道非活动的actors将被自动垃圾收集，但当它们被重新激活时，它们的状态将一直存在。我还看到有一种方法可以显式删除参与者及其状态。
在我的场景中，我想知道是否有任何模式或建议如何处理设备进入休眠，故障或“消失”，再也不会发送其他消息。如果没有明确的删除，他们的状态将永远存在，我想自动清除它，例如:六个月后。
浏览 1提问于2016-05-20得票数 2
可能重复: 当Ubuntu结冰时我该怎么办？
每天至少有一次，我在运行Ubuntu12.04的英特尔i5 (2台不同的)机器上失去了工作。整个系统会冻结/锁定/挂起，再也不会回来了。此时，什么也不起作用；甚至连大写锁键也不能打开键盘上的灯；Ctrl-Alt-F1也不会做任何事情。
很明显，askubuntu.com是我寻求支持的地方。
我怀疑这是一个内核错误。但是我不能一直失去这样的工作，所以我渴望尽我所能让它可靠地工作。
你能建议我
我可以试着解决这个问题
一个现有的bug，我可以跟踪进度，并贡献给(来自用户/测试人员的POV)
最有建设性的方式，我可以帮助解决问题，记住，我确实需要计算机
浏览 0提问于2012-06-27得票数 3
1回答
我在Dask中使用分布式计算为不同数量的工作人员获得了任务流。我可以观察到，随着工人人数的增加(从16人增加到32人)，任务流中的空白也增加了，从而降低了并行计算的效率。即使我增加了每个工人的工作量(即每个工人的计算数)，我也会得到类似的趋势。有人能建议如何减少空白吗？
PS:我需要把计算扩展到1000秒的工人，所以减少工人的数量对我来说不是一个选择。
图片：
图片：
图片：
浏览 6提问于2020-05-13得票数 1
回答已采纳
1回答
数列问题
、、
我们有一个问题，比我想要的更频繁，无论是工作者还是客户端会话崩溃，这些会话都在使用数字序列创建新记录的过程中，但它们最终会从字面上阻止该数字序列，任何试图使用相同序列创建记录的人都会冻结它的客户端。
当发生这种情况时，我通常进入NUMBERSEQUENCELIST表，找出正确的DataAreadId和用户，并删除Status = 1的行。
但这种事真的很烦人。有什么，任何方式，我可以配置AOS服务器释放号码序列时，客户/工人崩溃？
对于工作会话，我想我们可以很好地修改它们中运行的代码，但是对于客户端会话崩溃，我们无能为力.
有什么想法吗？
谢谢!
编辑：在这种情况下，在重新启动AOS服务器之后
浏览 1提问于2014-03-10得票数 2
回答已采纳
我有一些芹菜工人，他们执行的任务并不总是那么快。任务通常是一堆HTTP请求和DB查询(在SQLAlchemy后面使用pyscopg2 )。我在Kubernetes中运行，CPU使用率总是相当低(0.01左右)。Celery自动将并发设置为2(单个节点的核心数量)，但我想知道手动增加这个数字是否有意义。 我总是读到并发(进程？)应该与核的数量相同，但如果工人不使用整个核，它不能更多吗？就像concurrency=10一样？或者这不会有什么不同，我只是错过了进程和并发的要点？ 我找不到这方面的信息。谢谢。
浏览 15提问于2021-11-01得票数 0
回答已采纳
2回答
我有一个可以正常运行的Rails4.1应用程序，还有一个页面/app，它可以作为一个带有Backbone + Marionette的单页面web应用程序。
当我推送到Heroku时，我的应用程序将在所有页面上运行良好，直到我访问/app页面(加载主干环境)，在这一点上应用程序将超时。来自任何设备的后续请求都将正常工作。但是，如果dyno进入睡眠状态，那么重新唤醒后的第一个请求也将超时。
我认为这与资产预编译有关，但我不清楚如果dyno进入休眠状态，为什么资产会过期。
大约有50个js文件，编译后大约300kb。
是否存在此问题的已知问题或解决方法？
浏览 0提问于2014-04-02得票数 1
我有两个服务器，每个服务器上有一个芹菜工人。我使用Redis作为经纪人，与工人合作。
我的问题是，如何使大多数情况下只运行一个员工，一旦该员工被破坏，另一个员工将作为备用工作人员启动？
基本上，只要把一个工人当作后援就行了。
在读取了文档之后，我知道如何通过工人上的队列分别将任务指定给特定的工作人员。
浏览 1提问于2019-07-20得票数 1
回答已采纳
我似乎找不到很好的解释，如果几个工人听相同的AWS步骤函数活动ARN会发生什么？我主要对机制感兴趣，因为我正在探索如何在倾听分步功能活动的过程中引入容错，这意味着如果一个工人失败了，另一个工人如何从活动任务中恢复松懈呢？
如果有定义的模式-请共享：)
谢谢!
浏览 1提问于2018-03-08得票数 1
回答已采纳
1回答
据我所知，芹菜工人似乎停了下来，它应该能够在重新开始时从队列中消费。
为了测试这一点，我制作了3台虚拟机，每台机器都有2名芹菜工人。我用的是芹菜守护进程。一台机器有客户端脚本，另一台机器充当代理，尽管它们都运行着rabbitmq。
当我启动客户端脚本时，我的所有工作人员都会得到任务(从我所知道的日志中)。为了测试失败后会发生什么，我会发布
service celeryd stop
我的一台机器。然后一分钟后，我发布
service celeryd start
我一分钟前停下来的机器。但是，在发出此命令时，我的客户端脚本会冻结并停止运行，而上面机器上的工作人员再也不会接收任务。
知道这是怎么回事
浏览 1提问于2014-10-10得票数 1
回答已采纳
我试图迁移到现有解决方案的服务架构。部分原因是侦听队列的工人人数。例如，我有一些队列：
Task1_Queue, Task2_Queue ... TaskN_Queue
对于每个队列，都有一些处理它们的消息的逻辑，比如工人。它们执行不同的任务，比如生成巨大的报表文件并上传到Azure Storage，或者在数据库中进行小的更新。
问题是如何设计服务以使员工具有良好的可伸缩性。我的想法是：
选项1-每个队列将有单独的无状态服务。没有简单的方式自动规模的单一服务。
选项2-将工作人员实现为单独的参与者，并拥有单个无状态服务来侦听队列和调用参与者。优点-自动标度，对于来自队列的每一条消息，新的参与者
浏览 2提问于2017-08-15得票数 0
回答已采纳
1回答
当我回来的时候我需要为我的茶花创造一个条件。
目标是：
我验证电话号码并返回，我必须在屏幕上输入邮件地址和mobil号码。
我不验证电话号码和回来，我必须在屏幕上，我可以验证我的电话号码。
浏览 0提问于2018-05-17得票数 0
回答已采纳
我的应用程序有几个工作人员(作为不同的过程处理不同的事情)和一些资源(工作单元)。不同的工人需要处理所有的工作单位。例如，我有像W1、W2和W3这样的工人，还有工作单元U1和U2。然后W1需要处理U1和U2，就像处理W2和W3一样。限制是不同的工人不能同时在同一个工作单位工作。
我有两种设计，想征求意见，哪一种更好。
Push模型:使用中央作业调度器将工作单元分配给不同的工人，以确保不同的工人不在同一工作单元上工作；拉力模型:每个工人将要求中央作业调度器处理工作单元，而作业调度程序将选择其他工人没有处理的合适的工作单元。
我想知道每种设计的利弊。我主要关心的问题之一是--找到一个松散耦合的设计
浏览 5提问于2009-12-01得票数 6
回答已采纳
使用JRE6 ( Windows XP上的SUN VM )时，getLocalhost()有时会冻结。
有趣的是，如果在Eclipse的调试器中，它不会冻结。我使用老式的println将其缩小为一次getLocalhost()调用。据我所知，这段代码没有什么特别之处。
还有没有人见过这个问题？
浏览 3提问于2009-05-05得票数 1
我用一个扇子和一个回复在一个标题中地址。棘手的部分是，我想等待所有工人的答复，但我不知道我会收到多少(我不知道有多少工人，当我发送广播)。
有没有办法知道目前有多少工人有联系？
提前感谢！
浏览 3提问于2014-03-24得票数 2
回答已采纳
我已经创建了一个芹菜工人与一个单一的芹菜节拍调度任务，运行时间间隔为5秒。如何在不停止的情况下，动态地向芹菜工人添加另一个节拍任务？
示例
app.conf.update(
CELERY_TASK_RESULT_EXPIRES=3600,
CELERY_TIMEZONE = 'UTC',
CELERYBEAT_SCHEDULE = {
'long-run-5-secs': {
'task': 'test_proj.tasks.test',
'schedule'
浏览 13提问于2015-11-13得票数 6
回答已采纳
5回答
我有一个用芹菜做的项目。我周期性地遇到这样一种情况:我的请求正在向芹菜发出，但是任务并没有被传递给工人，而是服务器只是返回了一个500错误。
当我重新开始芹菜的时候，它又开始工作了。我只是猜测这个工人被绞死了，这样就没有工人了。如果我启动了另一批工人，请求就会重新开始工作(这支持了我的理论)。
问题：
我了解芹菜在默认情况下原木为stderr。我没有看到任何错误，所以我希望有另一个芹菜原木某处。那会在哪呢？
有没有办法查找工人的状况？有空房吗？挂起来了吗？
还能有别的事吗？
浏览 6提问于2016-04-12得票数 4
回答已采纳
我下面有个程序
package com;
public class ThreadDemo implements Runnable {
@Override
public void run() {
while(true)
{
try {
System.out.println("Into sleep");
Thread.sleep(1000000000);
System.out.println("Out of
浏览 2提问于2014-10-01得票数 1
回答已采纳
1回答
我有一个很大的任务，我把它分解成更小的任务，然后分析它们。我有一个基本的模型。
师父，工人和听众。
大师创建任务，并将其交给工作人员。一旦工作人员完成了任务，它就会要求主程序执行另一项任务。一旦所有任务都完成，它们就会通知侦听器。他们通常需要不到2分钟来完成1000项任务。
现在，某些任务所需的时间可能比其他任务的时间要长。我想为每个任务设置计时器，如果一个任务需要更多的时间，那么工作任务应该被主任务中止，任务必须作为新的任务重新提交。如何实现这一点？我可以计算一个工作任务所花费的时间，但是主演员是如何实时保持所有工人演员所占用的时间的呢？
浏览 0提问于2014-10-22得票数 1
回答已采纳
要获取芹菜任务的信息，我需要task_id。当手工启动芹菜任务时，我可以使用task.id轻松地获得此任务的id (并将其写入DB或执行其他操作)。如果我用芹菜打，它会定期地把任务交给工人，那似乎是不可能的。
所以我的问题是，如何从任务中得到id，拍打把任务发送给芹菜的工人？
当工作人员接收到任务时，控制台将显示任务id。所以我担心的是，在任务被敲打发送给工人的那一刻，它没有任务id。
获得task_id的手动案例：
task = tasks.LongRunningTask.delay(username_from_formTargetsLaden, password_from_formTarg
浏览 0提问于2019-06-27得票数 3
回答已采纳
我有一个Java程序，它不断地从外部系统发送UDP数据。
定期地，我们需要停止接收数据(因为另一台机器正在处理数据)。在此期间，我的套接字读取器线程进入睡眠循环。当开始接收数据包时，我再次进入socket.receive(Packet)，并有一个缓冲区，其中装满了我不应该处理的数据包。(数据是在“停止时间”时出现的。)
有办法清除DatagramSocket的缓冲区吗？
如果没有，最好的选择是什么？当我进入等待状态时，将缓冲区大小设置为0，并在我再次开始服务数据包时将其带回来？我等的时候关闭插座，回来的时候打开新的插座？
浏览 2提问于2011-12-08得票数 5
回答已采纳
我想在码头工人的帮助下使用Flink。我想以启动的形式运行Socketwordcount实例。但在这个阶段我遇到了一个错误。我不能连接套接字。因此，在20毫秒后，flink完成工作。
码头工人-组成：
version: "3"
services:
jobmanager:
image: ${FLINK_DOCKER_IMAGE_NAME:-flink:1.3.2-hadoop24-scala_2.11-alpine}
expose:
- "6123"
ports:
- "8081:8081"
浏览 0提问于2019-02-21得票数 3
回答已采纳
1回答
我正在尝试了解消息代理和队列是否可以实现以下功能：
假设我有一个任务队列，由一个worker在一个资源上执行。
我可以完全控制工人的数量。为了举个例子，这里有两个。
任务在单个资源上运行。我几乎无法控制这些资源的数量，我只知道一些任务将应用于相同的资源。资源的数量比任务的数量少很多倍。但一般来说，我不能启动与资源一样多的工人。
假设总共有10个资源。当任务在资源上运行时，其他工作进程不应启动在同一资源上运行的任务。
这可以用芹菜或rabbitmq来组织吗？也许我思考它的方式是错误的。
浏览 8提问于2018-01-30得票数 0
有时，当我从睡梦中恢复(也称为打开我的笔记本盖子，关闭它使其进入睡眠状态后)，返回密码提示只需要5-10秒甚至更短的时间。
其他时候，就像刚才一样，它花了近一分钟才真正回来。我看过从黑屏回来需要两分钟的时间。我曾经想过，当这件事发生时，电脑会冻结或停止在睡眠模式下工作，然后我很努力地关掉电源，现在我学会了耐心。
这是因为它正在进入挂起到磁盘模式，而不是挂起到内存吗？当这种情况发生时，我总是被插入，或者通常是这样，所以我不认为它必须挂在磁盘上。
另外，如果它挂在磁盘上导致了这种情况，那么屏幕上可能会出现一条“恢复”消息，以指示发生了什么事？
谢谢你对我如何解决这个问题的指导。
浏览 0提问于2012-06-22得票数 3
我可以调用下面的URL来了解骆驼路线部分的状态.
这会给
{
timestamp: 1425658189,
status: 200,
request: {
operation: "getState()",
mbean: "org.apache.camel:context=VCM047,name="VCM047_store_list_schedule",type=routes",
type: "exec"
},
value: "Started"
}
路线部分被定义为..。
<route id="VCM
浏览 4提问于2015-03-06得票数 0
回答已采纳
1回答
我试图获得正确的“结构”，以便使用(任务)异步/等待从外部源监视游戏的状态，以便在无限循环中运行任务，然而，其当前编写的方式似乎只是冻结了我的UI。
到目前为止我所拥有的是：
(在“状态机”类中)
// Start monitoring the game state for changes
public void Start()
{
tokenSource = new CancellationTokenSource();
CancellationToken token = tokenSource.Token;
IsRunning = true;
task = T
浏览 2提问于2016-04-24得票数 0
回答已采纳
2回答
我有一个相当长的Celery任务。不止几分钟。
有时，由于各种原因，一个工人被标记为终止，而另一个工人开始。如果需要替换运行在其上的机器，或者正在部署新的代码版本，就会发生这种情况。在这种情况下，工作人员接收SIGTERM信号。
我想知道任务本身是否有可能定期检查该工作人员是否收到了SIGTERM并正在等待终止，在这种情况下，只需将任务放回队列并终止即可。(然后，该任务将在另一个工人身上启动，并将继续进行其工作)
编辑:澄清-在任务中是否可以检查它是否在等待被终止的员工上执行。如下所示：
# Some long task that can take even a few hours.
def
浏览 2提问于2021-05-01得票数 4
回答已采纳
我有一个像这样的流应用程序：
DataStream<MyObject> stream1 = source
.keyBy("clientip")
.flatMap(new MyFlatMapFunction())
.name("Stream1");
//...
public class MyFlatMapFunction extends RichFlatMapFunction<MyObject, MyObject> {
private
浏览 11提问于2020-09-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
