Как настроить сеанс структурированной потоковой передачи Spark для служебной шины Azure? В настоящее время я использую лазурные блоки данных как потребитель для одной из подписок на тему служебной шины.
Я рассмотрел несколько вещей, но увидел проблемы вокруг этого -
https://github.com/elastacloud/servicebusreceiver
https://github.com/MicrosoftDocs/azure-docs/blob/master/articles/service-bus-messaging/service-bus-python-how-to-use-topics-subscriptions.md