问题标签 [netflix-conductor]

我一直在寻找比 AxonFramework 的 Saga 更复杂的工作流程——我们目前正在使用它——我在 Netflix Conductor 中找到了一个。可悲的是，我在互联网上搜索了一个像样的例子，但无济于事。

我的问题是，在 Netflix Conductor 中，如何定义和创建 Task 或 WorkflowTask，最重要的是，如何将微服务链接到它？这是来自 github 的 Netflix Conductor 代码：

请原谅我的困惑，因为我是 Netflix Conductor 的新手。

如何配置 Netflix 指挥运行独立弹性搜索而不是嵌入式弹性搜索？

我正在用导体创建一个 Worker 任务

http://localhost:8080/api/metadata/taskdefs

但收到此错误

我的任务定义 JSON 有效负载是

有没有人成功地将 Netflix Conductor 与 AWS SQS 集成？我已尝试以下步骤，但未触发工作流程。

1. 创建 SQS 队列
2. 将 AWS 信用添加到环境
3. 注册的任务、工作流和下面的事件监听器

我想知道是否有一种简单的方法可以连接 Kafka 和 Netflix Conductor（而不是 SQS）？目前，它似乎只适用于 Amazon SQS。此外，似乎只能按任务执行一项操作。有没有办法按任务执行多个操作？

提前致谢，

有人可以分享有关如何使用 Netflix Conductor 的教程吗？github上有没有类似代码示例之类的？我已经在 Amazon SWF 上完成了一个示例，并了解了整个工作原理，但需要一些关于开始使用 Conductor 的指示。

在我的 Windows 10 机器上，我试图在内存服务器中运行 Netflix Conductor。并在此命令上gradle server收到此错误。

我将 Netflix/Conductor 与docker-compose. 当我设置docker-compose.yml文件时，我看到与 dynomite 相关的行太多。我认为它会消耗大量内存并减慢我的系统速度。不得不提的是，Conductor 没有使用官方Netflix/Dynomite图片，而是使用了v1r3n/dynomite图片。有什么办法可以减少与之相关的日志数量？我知道 grep 可以减少日志，但我想更改日志级别或使用官方 dynomite 图像。我当前的 docker 文件（顺便说一下，它是 Netflix/Conductor github repo 中的官方版本）：

我创建了一个重试5次的任务。并使用http类型的任务（我的rest url api端点）作为输入参数创建了一个工作流。

但是在我运行工作流程的那一刻 - 它正在访问其余的 api。实际上我想通过工人运行任务 - 在我的休息服务中调用另一个上游服务。

我想要什么 - 其余 url(url-2) 是另一个 url(url-1) 的上游。当我的应用程序调用 url-1 时，在代码中我将使用指挥任务来击中 url-2，并根据状态或关闭，我将失败状态 - 它会重试。

我正在按照此处Netflix Conductor的步骤在我的桌面上本地安装和运行。我正在尝试使用docker-compose来启动所有服务。在错误的 docker 版本、docker compose 版本、docker compose build 问题（使用此解决）的初始问题之后，我遇到了这个错误的障碍 -

/conductor/docker$ sudo docker-compose up

docker_elasticsearch_1 是最新的

docker_dynomite_1 是最新的

错误：对于指挥服务器容器“a89b4c61d465”不健康。

错误：启动项目时遇到错误。

我还在 docker-compose.yaml、server/config/config.properties 和 server/config/config-local.properties 中将 elasticsearch 端口更改为 10300。

Docker 组合版本是 1.23.2。Docker 版本是 18.09.3。

PS：我对码头工人和相关概念非常陌生。

更多信息：将我的端口更改恢复为默认值（9200/9300）并添加了不健康容器的 docker 信息（docker container-id 由于重新构建而更改）

/conductor/docker$ sudo docker ps -a --filter "id=7be9f9b5288c" [sudo] anshuman 的密码：容器 ID 图像命令已创建状态端口名称

7be9f9b5288c docker.elastic.co/elasticsearch/elasticsearch:5.6.8 "/bin/bash bin/es-do..." 36 分钟前 36 分钟前（不健康）0.0.0.0:9200->9200/tcp，0.0.0.0： 9300->9300/tcp docker_elasticsearch_1

curl到elasticsearch似乎还可以。

/conductor/docker$ curl http://127.0.0.1:9200/_cat/health 1553188720 17:18:40 docker-cluster 黄色 1 1 5 5 0 0 5 0 - 50.0%

容器的 Docker 日志给了我这个（不知道它们的意思）

/conductor/docker$ sudo docker logs 7be9f9b5288c [2019-03-21T17:12:06,323][INFO ][oexmMachineLearningTemplateRegistry] [M5hkiIZ] 成功创建 .ml-meta 索引模板

[2019-03-21T17:12:06,413][INFO][oexmMachineLearningTemplateRegistry] [M5hkiIZ] 成功创建 .ml-notifications 索引模板

[2019-03-21T17:12:06,502][INFO][oexmMachineLearningTemplateRegistry][M5hkiIZ]成功创建.ml-anomalies-index模板

[2019-03-21T17:12:07,152][INFO][oelLicenseService][M5hkiIZ] 许可证 [dfac41a4-9280-4c77-81ef-0f943039ef77] 模式 [试用] - 有效

[2019-03-21T17:12:15,712][INFO][oecmMetaDataCreateIndexService] [M5hkiIZ] [.monitoring-es-6-2019.03.21] 创建索引，导致 [auto(bulk api)]，模板 [.monitoring-es ]，分片1 / 1，映射 [doc]

[2019-03-21T17:12:16,122][INFO][oecmMetaDataCreateIndexService] [M5hkiIZ] [.watches] 创建索引，导致 [auto(bulk api)]，模板 [watches]，分片1 / 1，映射 [watch]

[2019-03-21T17:12:16,728][INFO][oecmMetaDataMappingService][M5hkiIZ][.watches/t05gsw2UQjmWEJ9IiSKn6g]update_mapping [观看]

[2019-03-21T17:13:17,111][INFO][oecmMetaDataCreateIndexService][M5hkiIZ][.triggered_watches] 创建索引，导致 [auto(bulk api)]，模板 [triggered_watches]，分片1 / 1，映射 [triggered_watch]

[2019-03-21T17:13:17,644][INFO][oecmMetaDataCreateIndexService] [M5hkiIZ] [.monitoring-alerts-6] 创建索引，导致 [auto(bulk api)]，模板 [.monitoring-alerts]，分片1 / 1、映射[doc]

[2019-03-21T17:13:17,918][INFO][oecmMetaDataCreateIndexService] [M5hkiIZ] [.watcher-history-6-2019.03.21] 创建索引，导致 [auto(bulk api)]，模板 [.watch-history -6]，分片1 / 1，映射 [doc]

[2019-03-21T17:13:18,475][INFO][oecmMetaDataMappingService][M5hkiIZ][.watcher-history-6-2019.03.21/sP8OvfXNSmCImfRf3mCR3A]update_mapping [doc]

[2019-03-21T17:13:18,718][INFO][oecmMetaDataMappingService][M5hkiIZ][.watcher-history-6-2019.03.21/sP8OvfXNSmCImfRf3mCR3A]update_mapping [doc]