Как контролировать потоковые приложения Внутри SCDF?

Question

Я новичок в потоке данных Spring Cloud и Stream Stream Streaming Applications. В настоящее время моего проект схема выглядит следующим образом:

I маршрут запрос POST от внешнего клиента, используя Zuul шлюза API к microservice под названием Composite. Composite создает поток с использованием REST POST и развертывается на Spring Flow Data Server. Насколько я знаю, микросервисы mongodb и файл работают как совместные процессы JVM. Если мой клиент должен знать статус потока, состояние обработанных данных, как должен Composite Microservice взаимодействовать с Spring Cloud Data Flow Server? В настоящее время, когда я делаю запрос POST для развертывания потока, я даже не получаю статус от SCDF Server. Предоставляет ли SCDF какие-либо крючки для просмотра отдельных приложений? Также как я могу изменить поток @runtime для создания динамической сетки?

В настоящее время я использую локальный сервер потоков данных Spring Cloud для разработки.

Answer 1

выполнение платформа является локальной

Local выполнения рекомендуется только для целей развития, и если вы готовите для производства, пожалуйста, не забудьте выбрать вариант платформы (например, : УТС, K8S , пряжа, ..), которая поставляется с нефункциональными требованиями для поддержки надежного и долговременного выполнения всех приложений, работающих в потоковом конвейере.

Насколько я знаю, микросервисы mongodb и файл работают как совместные процессы JVM.

Если ваше определение потока file | mongodb, вы бы 2 разных JVM, даже когда с помощью Local выполнения. Это независимые приложения для загрузки.

Как должен Composite Microservice взаимодействовать с сервером потока данных Spring Cloud?

Непонятно, что вы подразумеваете под «составным» здесь. Все приложения микросервиса в SCDF взаимодействуют через промежуточное программное обеспечение для обмена сообщениями, такое как Kafka или Rabbit. SCDF обеспечивает возможность оркестровки для запуска таких приложений на разных платформах времени исполнения.

В настоящее время, когда я делаю POST вызов, чтобы развернуть поток Я даже получить статус от SCDF сервера

Вы можете использовать SCDF в REST-API, для запроса текущего состояния приложения, и это платформа агностик. Вы можете просмотреть список поддерживаемых API, нажав на корневой URL (см. Изображение ниже). В документах есть пробел - мы исправим его. Следующие API могут быть полезны для проверки состояния.

ли подвергать SCDF любые крючки, чтобы посмотреть на отдельных приложений?

После приложения развертывается в платформе выполнения, вы можете воспользоваться приводом оконечного ботинка, чтобы исследовать больше деталей, такие как trace, metrics, health, env среди других на каждом уровне приложений. Дополнительную информацию см. В разделе Boot's actuator endpoints. Например, если ваше приложение mongodb работает локально и на порту 23000, вы можете проверить гранулированные показатели для этого приложения по адресу: http://localhost:23000/metrics.

[В качестве FYI: будущие выпуски SCDF включают в себя интеграцию весенних ботинок + весеннего облака Sleuth и визуальное представление того же самого.]

Также как изменить поток @ времени на создание динамической сетки?

Если вы имеете в виду редактирование работающего потокового конвейера с добавлением/удалением, в настоящее время мы изучаем подход к дизайну для поддержки этой функции.