Не удается запустить приложение HTTP (источник) spring-cloud-dataflow
Я следовал руководству по созданию потока с потоком данных spring-cloud-data. Он создает следующий поток -
http --port=7171 | transform --expression=payload.toUpperCase() | file --directory=c:/dataflow-output
Все три приложения запускаются нормально. Я использую rabbitMQ, и если я войду в пользовательский интерфейс кролика, я вижу, что для потока создаются две очереди. В руководстве сказано, что я могу отправить сообщение на http://localhost:7171/ с помощью почтальона. Когда я это делаю, ничего не происходит. Я не получаю ответа, ничего не вижу в очередях и файл не создается. В моих журналах потока данных я вижу это в списке.
local: [{"targets":["skipper-server:20060","skipper-server:20052","skipper-server:7171"],"labels":{"job":"scdf"}}]
В учебнике использовалась более старая версия потока данных, в которой, как мне кажется, не использовался шкипер. Поскольку я использую шкипера, изменится ли это URL-адрес? Я пробовал http://skipper-server:7171/ и http://localhost:7171/, но ни один из них, похоже, не достигает конечной точки. Я отключил проверку сертификата SSL в настройках почтальона.
Извините за то, что задал так много вопросов о потоках данных на этой неделе. Заранее спасибо.
1 ответ
Я обнаружил, что порт, который я пытался открыть (7171) на моем шкиперском сервере, не был открыт. Мне пришлось добавить и открыть порт в конфигурации сервера шкипера в моем файле.yml. Я нашел этот пост, который меня прояснил.
Как отправить HTTP-запросы на мой сервер, работающий в контейнере докера?
skipper-server:
image: springcloud/spring-cloud-skipper-server:2.1.2.RELEASE
container_name: skipper
expose:
- "7171"
ports:
- "7577:7577"
- "9000-9010:9000-9010"
- "20000-20105:20000-20105"
- "7171:7171"
environment:
- SPRING_CLOUD_SKIPPER_SERVER_PLATFORM_LOCAL_ACCOUNTS_DEFAULT_PORTRANGE_LOW=20000
- SPRING_CLOUD_SKIPPER_SERVER_PLATFORM_LOCAL_ACCOUNTS_DEFAULT_PORTRANGE_HIGH=20100
- SPRING_DATASOURCE_URL=jdbc:mysql://mysql:1111/dataflow
- SPRING_DATASOURCE_USERNAME=xxxxx
- SPRING_DATASOURCE_PASSWORD=xxxxx
- SPRING_DATASOURCE_DRIVER_CLASS_NAME=org.mariadb.jdbc.Driver
- SPRING_RABBITMQ_HOST=127.0.0.1
- SPRING_RABBITMQ_PORT=xxxx
- SPRING_RABBITMQ_USERNAME=xxxxx
- SPRING_RABBITMQ_PASSWORD=xxxxx
entrypoint: "./wait-for-it.sh mysql:1111-- java -Djava.security.egd=file:/dev/./urandom -jar /spring-cloud-skipper-server.jar"