网飞指挥 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"
    }
  }]
}

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