Apache Flink внешний вызов API - PullRequest
Новая
       33

Apache Flink внешний вызов API

0 голосов
/ 27 апреля 2018

Можно ли вызвать внешний API (RESTful) внутри кода Apache Flink. Если это возможно, то как мы можем это сделать.

Я вызываю API из простого Java-кода, он работает нормально, но когда я использую тот же код в Apache Flink, выдается исключение: 

java.io.IOException: Server returned HTTP response code: 500 for URL: http://example.com/someapi

1 Ответ

0 голосов
/ 27 апреля 2018

Можно ли вызвать внешний API (RESTful) внутри кода Apache Flink. Если это возможно, то как мы можем это сделать.

Вы можете использовать функцию асинхронного ввода-вывода, предоставляемую в Flink Streaming API. Асинхронный API ввода / вывода Flink позволяет пользователям использовать клиенты асинхронных запросов с потоками данных. Больше подробностей и примеров здесь .

java.io.IOException: сервер вернул код ответа HTTP: 500 для URL: http://example.com/someapi

Похоже, что ошибка не мигает, поскольку ответ равен 500. Проверьте заголовки / параметры запроса, которые отправляются, и проверьте, правильно ли создается запрос http. Попробуйте некоторые утилиты, такие как PostMan, чтобы сначала протестировать API.

...