Netflix Conductor SQS

Question

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

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

{
  "name": "sqs_event_listener",
  "event": "sqs:name_of_sqs_queue",
  "condition": "true",
  "active": true,
  "actions": [{
    "action": "start_workflow",
    "start_workflow": {
      "name": "mywf"
    }
  }]
}

- danca

Answer 1

我知道现在回答原帖已经太晚了，但是为了提高SO的集体智慧，我还是要回答一下：

在你的Conductor application.properties文件中，请确保你有以下数值：

conductor.default-event-queue.type=sqs
conductor.event-queues.sqs.enabled=true
conductor.event-queues.sqs.authorized-accounts=(your AWS account number)

我们需要更新 annotations-processor/awssqs-event-queue/src/main/java/com/netflix/conductor/SQSEventQueueConfiguration.java。

    @Bean
    AWSCredentialsProvider createAWSCredentialsProvider() {
        return new DefaultAWSCredentialsProviderChain();
    }

在Conductor中进行这个配置后，您现在可以重新启动实例，然后您的事件应该能够从SQS消息队列接收到事件。

如果您想了解完整的工作流程和发送/接收SQS消息的任务，请查看：https://orkes.io/content/docs/how-tos/Tasks/SQS-event-task

- Doug Sillars