从第一个worker调用第二个worker时，如何获取第二个worker中的作业id
在云计算领域中，当第一个worker调用第二个worker时，可以通过以下方式获取第二个worker中的作业id：
- 使用消息队列：可以使用消息队列作为中间件，第一个worker将作业id发送到消息队列中，第二个worker从消息队列中获取作业id。消息队列可以实现异步通信和解耦，常见的消息队列产品有腾讯云的消息队列 CMQ（产品介绍链接：https://cloud.tencent.com/product/cmq）。
- 使用共享数据库：第一个worker将作业id存储在共享数据库中，第二个worker从数据库中读取作业id。共享数据库可以是关系型数据库（如MySQL）或者NoSQL数据库（如MongoDB），腾讯云提供了云数据库 TencentDB（产品介绍链接：https://cloud.tencent.com/product/cdb）和云数据库 MongoDB（产品介绍链接：https://cloud.tencent.com/product/cmongodb）。
- 使用分布式缓存：第一个worker将作业id存储在分布式缓存中，第二个worker从缓存中获取作业id。分布式缓存可以提供高性能的数据访问，腾讯云提供了云原生分布式缓存 TKE Cache（产品介绍链接：https://cloud.tencent.com/product/tke-cache）。
- 使用HTTP请求：第一个worker通过HTTP请求将作业id传递给第二个worker。可以使用HTTP的POST或GET方法传递参数，第二个worker通过解析HTTP请求获取作业id。
需要注意的是，以上方法仅是获取第二个worker中的作业id的一种方式，具体选择哪种方式取决于系统架构和需求。在实际应用中，还需要考虑数据安全性、性能要求、可扩展性等因素。
相关·内容
1回答
python-rq Queue.job_ids始终为空
python、flask、redis、python-rq
我的rq任务运行正常，但获取所有作业的函数都不起作用--redis==2.10.6>>> job = q.enqueue('app.tasks.example', 100)
>>> job.g
浏览 14提问于2018-07-29得票数 2
回答已采纳
1回答
从第一个worker调用第二个worker时，如何获取第二个worker中的作业id
ruby-on-rails、jobs、sidekiq
我使用sidekiq来处理后台作业。class MainWorker Rails.logger.info "In MainWorker, job id #{jid}#{jid}"end 我从MainWorker给SampleWorker打电话。当我打印时，我在MainWorker中获得Sidekiq作业id。但是当我打印时，我在SampleWork
浏览 19提问于2019-05-04得票数 0
2回答
使用Pheanstalk的PHP进程派生
php、fork、pheanstalk
(我知道这可能会炸毁服务器；有一些额外的保障措施不在这个问题的讨论范围之内)$pids = array();while ($ok)我的问题是，pheanstalk如何返回一个没有ID
浏览 9提问于2014-05-30得票数 1
2回答
并行map与并行for-loop的区别
parallel-processing、julia、distributed、pmap
当我阅读多核并行计算的Julia文档时，我注意到有并行映射pmap和for-loop @distributed for。从文档中可以看出，“Julia的pmap是为每个函数调用做大量工作的情况而设计的。相比之下，@distributed for可以处理每次迭代都很小的情况”。pmap和@distributed for之间的区别是什么？为什么@distributed for在处理大量工作时速度很慢？
谢谢
浏览 9提问于2019-04-16得票数 9
2回答
在不事先知道N个工人的情况下，在主管中申报N个工人的最佳方法
erlang、erlang-otp
每个工作人员只需打开一个tcp套接字，执行一个侦听，然后接受连接，在每个客户端到达时生成一个进程(我不介意监督这些进程)。我希望在应用程序配置中配置侦听地址，这样我就可以根据需要拥有尽可能多的侦听地址(至少需要一个地址，但可以指定任何数字)。每个地址都是一个ip (或主机名)和一个端口地址。到目前为止没有什么新的。我的问题是如何申报、启动和监督数量不详的工人。我的解决方案是在运行时动态生成监控程序代码中init/1函数<em
浏览 0提问于2012-05-04得票数 2
回答已采纳
1回答
开放类之间的通信
java、swing、user-interface、awt
另外两个是GUI类，其中一个调用另一个。调用第二个GUI类的类打开了worker类。第一个GUI使用此方法调用第二个GUI： add.setVisible(true);第二个GUI类用于从在wor
浏览 1提问于2015-01-12得票数 1
回答已采纳
1回答
Laravel长时间运行队列作业由第二个worker挑选
laravel、queue、supervisord
我对添加到队列中的laravel长时间运行的进程有问题。使用数据库驱动程序和supervisord。问题是，在工人#1挑选这个工作之后，它必须做一些繁重的处理(从5到20分钟)，到那时，工人#2也挑选这个工作！如何处理这个问题？我如何添加这些长时间运行的作业： Artisan::queue('process:import', [
'file' => $file_to_import-
浏览 24提问于2020-01-07得票数 0
2回答
如何使这个去代码打印在3秒内？
go、time、concurrency、channel、goroutine
这是Go代码 ch := make(chan int)
time.Sleep(3 * time.Second) }()
}
timeStart := time.Now()
println(int(time.Since(timeStart).Second
浏览 1提问于2020-08-19得票数 1
回答已采纳
2回答
PHP + MySQL循环队列
php、mysql、queue、cycle
我刚刚接受了一个类似的问题()，但我意识到这不是针对我的问题的正确问题，而是我的问题的正确答案:) `id` int(11) NOT NULL auto_increment, `last_pop` int(13) defaultNULL, `disabled`
浏览 0提问于2009-11-07得票数 1
回答已采纳
3回答
QThread::wait()不使用直接连接就不会返回
c++、qt、qt5、qthread、qtcore
我找到了关于这个主题的几个教程和讨论，我遵循创建了这个线程。但是我仍然有一个问题，就是线程上的调用wait()永远不会返回，UI也会冻结。前面有一个类似的问题(第二个例子)：我还创建了一个简化为核心问题<
浏览 1提问于2013-12-17得票数 6
回答已采纳
1回答
2次迭代数组，等待时间最短(动态编程)
c++、arrays、algorithm、optimization、dynamic-programming
我们得到一个大小为n的整数数组，这些整数表示完成某项任务的时间。两个工人需要在最短的时间内完成这些工作，尽管他们不能重叠。假设给定的数组大小为4，数字为1, 2，4 ,5。第一个worker执行order1 2中的作业，第二个worker按2 4的顺序执行作业。因此，完成这些作业所需的最少时间为12个单位，因为没有重叠。如果数组
浏览 0提问于2021-03-14得票数 0
1回答
指定芹菜中的Worker
python、celery、flower
我有两个工人： celery worker -l info --concurrency=2 -A o_broker -n main_worker
celery worker -l info --concurrency=2 -A o_broker -n second_worker 我正在使用for来监控和接收这些工作人员的API请求： flower -A o_broker 为了从API启动这些芹菜工作进程，我在docs我需要选择运行特定的代理来完成任务。 我如何<
浏览 13提问于2019-01-31得票数 0
2回答
如何在函数式编程中实现带有隐藏参数的函数？
functional-programming、lua
在Java中，我会这样做：public Link buildChain() {}
private Link现在我该如何以函数式的方式实现它呢？那个类Link将是一个表(在Lua中)，存储父链接和子链接以及link所需的任何其他内容。但是我该如何做这两个功能呢？我会使用闭包(尽管私有方法不使用公有方法的局部变量)还是一种反向的curryin
浏览 2提问于2011-04-07得票数 0
回答已采纳
1回答
任意逻辑问题:一台机器中两个操作时间不同的算子
simulation、anylogic、event-simulation
我正在努力解决任何逻辑中的模拟问题。如何使用流程图块对此问题进行建模？
浏览 4提问于2020-03-03得票数 0
回答已采纳
1回答
用于2个作业的python异步信号量循环后发布
python、semaphore
我需要使用信号量或一些锁来解决两个异步作业的问题。我需要在每个作业的while循环中将控制从一个传递到另一个。第一个作业将永远运行，第二个作业最终将完成。main())loop.close() 但在我的代码中，只有两个作业中的一个可以工作，并且在当前作业完成之前不
浏览 13提问于2020-04-07得票数 0
4回答
设计模式-策略模式
design-patterns、strategy-pattern
我是设计模式的初学者。我正在尝试从策略模式中获得灵感。因此，我将我的类和接口设计如下：{ void TakesLeave();
interface IResponsible
浏览 1提问于2009-06-19得票数 7
回答已采纳
1回答
多线程会导致Qt中的运行时错误。
c++、multithreading、qt、qthread
例如，当我试图在Qt中执行多线程时：QThread thread;worker.moveToThread(thread);但是，如果我按这样的指针创建类对象：Worker* worker = new Worker();
worker->moveToTh
浏览 4提问于2018-01-12得票数 1
回答已采纳
1回答
更改变量名称会影响代码行为
python、selenium、process、multiprocessing、terminate
当我运行这段代码时，其中一个selenium窗口没有关闭 import multiprocessing
self.driver.get('https://www.google.com')
for i in range(2): process = multiprocessi
浏览 40提问于2020-06-09得票数 1
回答已采纳
1回答
停止Javascript计时器
javascript、jquery
为了检查任务是否已经成功完成，我使用了Javascript (我很糟糕)，更具体地说，使用jQuery/AJAX来不断地查询服务器，查看wkhtmltopdf的进程是否已经结束。如果进程已成功结束，则生成指向PDF的html链接，然后将其转储到<div></div>中。 pdf(); //
浏览 3提问于2013-12-13得票数 1
回答已采纳
1回答
延迟的作业工作人员执行正在运行的作业
ruby-on-rails、ruby、multithreading、ruby-on-rails-4、delayed-job
我的环境: CentOS、Rails4、Ruby2。任务是同时运行多个进程，以便从不同的站点获取信息。将其添加到DJ队列中。
因此，当我运行一个worker时，它成功地从队列中获取第一个作业，当作业完成时，获取下一个
浏览 2提问于2014-07-30得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
