问题标签 [netflix-conductor]

我们目前正在研究一种方法，该方法将与多个微服务协作，为我们提供解决方案。

数据流示例：

这些服务将部署在前面有 ALB 的 ECS 中。我想为系统整合一个工作流程，并需要以下帮助：

1. 我们计划将 Route 53 DNS 服务用于服务发现。我知道指挥使用 Eureka 客户端进行服务发现。是否可以只使用基于 DNS 的实现而不是 Eureka？

2. Conductor 可以部署为 ECS 集群中的 docker 镜像吗？我可以在 ECS 集群内部创建它而不将其部署在 EC2 服务器上吗？任何有帮助的文件？我们是维护 Docker 镜像还是需要创建自己的镜像？

在 netflix 指挥上设置健康检查的方法是什么？有一个健康检查的端点，但即使 dynomite 有一些问题，它也总是返回健康的。

返回

如果 dynomite 或弹性搜索失败，则指挥运行状况检查应返回 false。我如何让这个工作？

我正在尝试使用此module https://www.npmjs.com/package/conductor-client?activeTab=readme

我运行文档中给出的相同示例得到以下错误

https://codesandbox.io/s/thirsty-grass-ixm63

文档 https://github.com/devit-tel/conductor-nodejs-client#readme

我运行 Netflix 指挥 docker (conductor/docker docker-compose.yaml)。Docker 启动和上传工作流：

• ephemeralKitchenSinkEphemeralTask​​s
• 临时KitchenSinkStoredTasks
• 厨房水槽

如何防止运行这些工作流程？

我们使用 MySQL 作为与 Netflix Conductor 合作的数据库。是否可以设置时间来保持工作流执行历史（在 MySQL 和 Elasticsearch 中）？

我以前一直Netflix Conductor用作工作流编排，Apache Airflow对我来说是新的。在 Conductor 中，工作流的执行按以下步骤进行：

1. 工作流通过 REST API 调用开始
2. 每个单独的工作者（服务）通过不断调用 Conductor 的 REST API 方法来轮询自己的任务
3. 在完成或失败这些任务后，每个工作人员调用 REST API 来更改工作流的状态

这些任务中的每一个工作人员都是单独的服务。它们在不同的编程语言上实现。

我似乎找不到任何关于如何在Apache Airflow. 在我看来，不断使用BashOperator似乎非常糟糕的解决方案。

是否有任何示例说明如何使用工作人员（其中一些不是在 python 上编写的）来监听和执行其在 DAG 中定义的任务？

我对使用 API 很陌生，所以如果这真的很琐碎，请原谅我。

我想使用两个 GET 请求：

• /workflow/search将允许我获得完整的工作流列表及其数据（即工作流 ID）。
• /workflow/{workflowId}将允许我获得具有更多详细信息的特定工作流程。

我目前importedWorkflows在我的数据函数中，其中填充了我从/workflow/search调用中获得的内容。如果我想了解有关工作流程的更多信息，那么我想致电/workflow/{workflowId}.

然而，这真的很困难，尤其是因为我使用 Jquery 来获取 JSON 数据。

由于它都是异步的，我真的只想在/workflow/{workflowId}准备好时访问找到的信息。

这是我实现这一目标的尝试：我已经计算了调用数组importedWorkflowDefinitions，它遍历了所有找到的工作流，并对每个工作流/workflow/search进行/workflow/{workflowId}调用。我将每个调用返回的 JSON 数据存储在计算数组中。然后，我使用一种方法调用generateWorkflowById()来查找工作流 JSON 中的importedWorkflowDefinitions.

然而...

在我的 Vue 应用程序中，我有一个使用 v-for 指令制作的表格。

注意： workflowsOnPage是一个计算出来的 JSON 数组，将importedWorkflows.

所以，本质上发生的事情是表格将呈现没有generateWorkflowById(workflow.workflowId).workflowName值，因为第一次调用/workflow/search还没有完成。此外，即使workflowDefinitions已计算并且在/workflow/search调用完成时会更改，表已经完成渲染并且不会generateWorkflowById(..)再次运行该方法。

有没有办法将通过/workflow/{workflowId}调用找到的信息呈现到表格上，而我的所有数据都不会发生这种竞争？

顺便说一句，我正在与 Netflix Conductor 合作，所以如果有更好的 API 调用或不同的方式来访问与工作流有关的所有详细信息，因此我不必进行这些依赖 API 调用，请告诉我知道！

谢谢！

我正在浏览 Netflix Conductor 文档。它一直在使用任务轮询和循环轮询，但我似乎无法理解它。请帮忙。TIA。

只有几个任务可以异步运行：HTTP、EVENT、KAFKA。但是为什么没有办法异步运行简单的任务。特别是异步运行子工作流的非常有用的功能。唯一的解决方法（并且仅适用于子工作流）是发送将由注册事件处理的事件，该事件将运行工作流

我一直在尝试使用 docker 安装导体，但我一直在出错。我尝试使用本文中给出的 [https://github.com/Netflix/conductor/tree/main/docker][1] 命令。但是第一个命令不起作用（gradlew build）我改为使用 gradlew init。运行第二个命令时（docker build -tconductor:server ./server）

我正在使用 Windows 我尝试将 RUN ./gradlew build -x test 更改为 .\gradlew,gradlew,gradle,..\gradlew,../gradlew 但没有任何效果。

谢谢