Выполнение задачи весеннего облака, основанной на событии в источнике обмена сообщениями (т. Е. RabbitMQ, Kafka)

Question

Я новичок в изучении Весеннего облака Задача и SCDF, так что прошу об этом.

Я палочка, чтобы выполнить свою SCT на основе события (скажем, сообщение опубликовано в Rabbit MQ), поэтому я думаю, что это может быть сделано двумя способами:

1. Создать источник, сообщение опросы из RabbitMQ и отправляет данные в поток, теперь создайте приемник, который считывает данные из потока, и как только данные опустится (из потока источника) будет запущена задача.

   create steam producer --definition "rabbitproducer | streamconsumer (This is @TaskEnabled)" 
   

   Не уверен, что это возможно?

2. Другой способ может заключаться в использовании пусковой установки задач. Здесь task launcher будет сконфигурирован с потоком, и слушатель будет опросить сообщение от rabbitMQ. поэтому, когда сообщение получено, триггер инициирует процесс, и tasklauncher запустит задачу. Но вот не уверен, как я получу данные сообщения в свою задачу? Нужно ли добавлять данные в TaskLaunchRequest?

   create stream mystream --definition "rabbitmsgtrigger --uri:my task | joblauncher" 
   

Answer 1

Запуск задачи предвключенным события уже поддерживается и существует несколько подходов к нему - пожалуйста, ознакомьтесь с reference guide (и образец) для получения более подробной информации.

Answer 2

Вот полное объяснение относительно моего вопроса. Здесь Сабби очень помог мне решить мою проблему.

Проблема: я не смог запустить свою задачу с помощью tasklauncher/task-sink. В журнале также я не получал правильных данных, и я даже не знал, как правильно установить уровень журнала.

Решение: с помощью Sabby и документации, предоставленной на сайте SCT, я мог бы решить эту проблему и продвинулся вперед в моей работе POC. Ниже приведены подробные шаги, которые я сделал.

1. начал свою SCDF с базой данных PostgreSQL, обращаясь к файлу свойств и настройка изменения уровня журнала, как

   --logging.level.org.springframework.cloud=DEBUG 
   --spring.config.location=file://scdf.properties 
   

2. ввезенных приложения из Bitly.

   app import --uri [stream applications link][1] 
   

3. Registered раковина задача приложения

   app register --name task-sink --type sink --uri file://tasksink-1.1.0.BUILD-SNAPSHOT.jar 
   

4. Созданный поток, как:

   stream create mytasklaunchertest --definition "triggertask --triggertask.uri=https://my-archiva/myproject-scdf-task1/0.0.1-SNAPSHOT/myproject-scdf-task1-0.0.1-20160916.143611-1.jar --trigger.fixed-delay=5 | task-sink" 
   

5. Развернутые поток:

   stream deploy foo --properties "app.triggertask.spring.rabbitmq.host=host,app.triggertask.spring.rabbitmq.username=user,app.triggertask.spring.rabbitmq.password=pass,app.triggertask.spring.rabbitmq.port=5672,app.triggertask.spring.rabbitmq.virtual-host=xxx"