码迷,mamicode.com
首页 > 其他好文 > 详细

Conductor Task Workers

时间:2017-06-14 23:31:04      阅读:627      评论:0      收藏:0      [点我收藏+]

标签:注册   sed   property   use   时间   pytho   全局   netflix   tor   

由远程worker执行的conductor任务通过HTTP端点进行通信以轮询任务并更新执行状态。

conductor提供了轮询任务的框架,管理执行线程并将执行状态更新回服务器。该框架提供了Java和Python中的库。可以通过使用用于任务管理的HTTP端点来添加其他语言支持。

Java

  1. 实现Worker接口来实现任务。https://github.com/Netflix/conductor/blob/dev/client/src/main/java/com/netflix/conductor/client/worker/Worker.java
  2. 使用WorkflowTaskCoordinator注册工作人员并初始化轮询循环。 https://github.com/Netflix/conductor/blob/dev/client/src/main/java/com/netflix/conductor/client/task/WorkflowTaskCoordinator.java

  • 示范worker实施   https://github.com/Netflix/conductor/blob/dev/client/src/test/java/com/netflix/conductor/client/sample/SampleWorker.java
  • 例  https://github.com/Netflix/conductor/blob/dev/client/src/test/java/com/netflix/conductor/client/sample/Main.java

WorkflowTaskCoordinator

管理任务工作线程池和服务器通信(轮询,任务更新和确认)。

worker

属性描述
paused 布尔值。如果设置为true,则worker停止轮询。
pollCount poll的任务数量。用于批量轮询。每个任务在单独的线程中执行。
longPollTimeout 以毫秒为单位的长时间轮询指定服务器的任务时间

这些属性可以由Worker实现或通过在JVM中设置以下系统属性设置:

conductor.worker.<property> 适用于JVM中的所有worker
conductor.worker.<taskDefName>.<property> 适用于指定的worker。覆盖全局属性。

 

Python

https://github.com/Netflix/conductor/tree/dev/client/python

按照自述中记录的示例进行操作,或查看kitchensink_workers.py

https://github.com/Netflix/conductor/blob/dev/client/python/kitchensink_workers.py

 

Conductor Task Workers

标签:注册   sed   property   use   时间   pytho   全局   netflix   tor   

原文地址:http://www.cnblogs.com/mhc-fly/p/7011459.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!