mqtt_sub.py

# هذا العمل مرخص بموجب ترخيص MIT.
# حقوق النشر (c) 2013-2023 OpenMV LLC. جميع الحقوق محفوظة.
# https://github.com/openmv/openmv/blob/master/LICENSE
#
# مثال على MQTT.
# يوضح هذا المثال كيفية استخدام مكتبة MQTT للاشتراك في موضوع (topic).
#
# 1) انسخ مكتبة mqtt.py إلى ذاكرة تخزين OpenMV.
# 2) شغّل هذا السكربت على كاميرا OpenMV.
# 3) ثبّت عميل mosquitto على جهاز الكمبيوتر وشغّل الأمر التالي:
#    mosquitto_pub -t "openmv/test" -m "Hello World!" -h test.mosquitto.org -p 1883
#
# ملاحظة: إذا تعذّر الوصول إلى وسيط mosquitto، جرّب وسيطاً آخر (مثال: broker.hivemq.com أو broker.emqx.io)

import time
import network
from mqtt import MQTTClient

SSID = ""  # اسم الشبكة (SSID)
KEY = ""  # مفتاح الشبكة

# تهيئة وحدة wlan والاتصال بالشبكة
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(SSID, KEY)

while not wlan.isconnected():
    print('Trying to connect to "{:s}"...'.format(SSID))
    time.sleep_ms(1000)

# يجب أن يكون لدينا الآن عنوان IP صالح عبر DHCP
print("WiFi Connected ", wlan.ifconfig())

client = MQTTClient("openmv", "test.mosquitto.org", port=1883)
client.connect()


def callback(topic, msg):
    print(topic, msg)


# يجب تعيين دالة الاستدعاء (callback) أولاً
client.set_callback(callback)
client.subscribe("openmv/test")

while True:
    client.check_msg()  # استطلاع الرسائل (poll).
    time.sleep_ms(1000)