Наши пограничные устройства основаны на пограничной среде выполнения IoT Azure.Одним из модулей, который отвечает за обработку данных, является пользовательский модуль, работающий под управлением версии Apache Nifi.Выходные данные обработки должны поступать на шину пограничных сообщений IoT Azure и / или в восходящее облако через IoT-концентратор.
Кто-нибудь знает, как подключить эти части пограничной системы?Нужно ли писать код C # в пользовательском модуле, чтобы сделать это, или есть другой способ сделать это?
Редактировать:
После дальнейшего изучения я узнал, что могу подключиться к IoT Hubиспользование MQTT в соответствии с this и взаимодействие с локальной шиной сообщений должно быть возможно путем написания пользовательского процессора Nifi, как показано here , с использованием Java SDK ModuleClient,просто предоставив правильную строку подключения и убедившись, что пользовательский контейнер может связаться с хостом через IP.
Как вы думаете, мои предположения верны для достижения нашей цели?