Как подключиться к брокеру MQTT с авторизацией в MQTT Библиотека потоков Spark

Question

Я пытаюсь подключить брокер с авторизацией (BlueMix IoT Foundation), но не знаю, как предоставить учетные данные? Как мне это сделать с помощью Spark?

Answer 1

Невозможно подключиться к брокерам с авторизацией с использованием соединителя MQTT по умолчанию от SparkStreaming. Вы должны переопределить MQTTInputDstream по-своему, чтобы включить аутентификацию.

Answer 2

я настроил библиотеку искровым потокового MQTT-разъем от Apache Спарка и добавил следующее,

• Добавлена ​​TLS v1.2 безопасности таким образом, что связь всегда обеспечена.
• Сохраненная тема вместе с полезной нагрузкой в ​​RDD.

Библиотека доступна здесь - https://github.com/sathipal/spark-streaming-mqtt-with-security_2.10-1.3.0. Кроме того, добавлено более подробное описание того, как использовать библиотеку для подключения к платформе IBM Watson IoT. Дайте мне знать, если у вас есть какие-либо вопросы.