Лазурь + очередь на служебный автобус
Мне нужно настроить очередь служебной шины в задании потоковой аналитики. У меня есть одна варочная панель событий из двух устройств. Один вход для задания потоковой аналитики. но 2 выхода. Один для базы данных, а другой для очереди служебной шины. Для служебной шины я написал запрос с предложением where, но сообщение не помещается в очередь. Я не развернул какой-либо конкретный код для отправки сообщения в очередь в виде потока Аналитическая работа выполняется так же. Но когда я удаляю предложение where, все данные отправляются. Можете ли вы помочь?