Netflix Проводник 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:

В вашем проводнике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