У меня есть конвейер JDBC, который отлично работает, но вместо того, чтобы планировать его запуск так часто, мы бы хотели, чтобы он работал по требованию, когда другая система решит, что он должен работать. Я подумал, что сделаю это, бросив сообщение в очередь SQS. Я получил logstash для возможности извлечения данных из sqs, и это здорово, но могу ли я просто использовать это сообщение для запуска конвейера ввода JDBC?
Для бонусных баллов можно ли использовать данные из сообщения SQS в выражении JDBC sql? Например, если сообщение содержит «{group: 123}», SQL может использовать это значение для чего-то вроде «select * from people, где group = 123»
Спасибо