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

Question

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

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

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

Answer 1

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

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

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

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