Quectel stuff

Author: craigt543nz

Examples/ex06_LE910Q1.py

@@ -0,0 +1,53 @@
+"""Under Active Development - INCOMPLETE!"""
+
+# import dashio
+from dashio import telit_LE910Q1
+import time
+import logging
+from dashio.iotcontrol.enums import ConnectionState
+
+
+logging.getLogger('dashio').setLevel(logging.DEBUG)
+
+formatter = logging.Formatter("[%(asctime)s][%(module)15s] -- %(message)s")
+handler = logging.StreamHandler()
+handler.setFormatter(formatter)
+logger = logging.getLogger()
+logger.addHandler(handler)
+logger.setLevel(logging.DEBUG)
+
+
+def _on_mqtt_connect(connected: bool, error_state: telit_LE910Q1.ErrorState):
+    if connected:
+        logger.debug("MQTT connected OK")
+
+        time.sleep(5)  # ???
+        control_topic = "craig/TELIT_DEVICE_ID/control"
+        lte.subscribe(control_topic)
+    else:
+        logger.debug("MQTT disconnecting reason  %s", error_state)
+
+
+def _on_mqtt_subscribe(topic: str, error: int):
+    logger.debug("Subscribed: %s %s", topic, str(error))
+
+    announce_topic = "craig/TELIT_DEVICE_ID/announce"
+    announce_message = "\tTELIT_DEVICE_ID\tWHO\tTelit_TYPE\tTelit_Test\n"
+    lte.publish_message(announce_topic, announce_message)
+
+
+def _on_mqtt_receive_message(message: str):
+    try:
+        logger.debug("LTE Rx ←\n%s\n", message.rstrip())
+    except UnicodeDecodeError:
+        logger.debug("LTE SERIAL DECODE ERROR Rx:\n%s\n", message)
+
+
+lte = telit_LE910Q1.LE910Q1("/dev/cu.usbmodem1103", "", "iot.gdsp.nz", 115200)
+lte.mqtt_setup("dash.dashio.io", 8883, "craig", "ThingyThing")
+lte.set_callbacks(_on_mqtt_connect, _on_mqtt_subscribe, _on_mqtt_receive_message)
+lte._will_topic = "craig/TELIT_DEVICE_ID/data"
+lte.run()
+
+while True:
+    time.sleep(1)

Examples/ex07_EG800Q.py

@@ -0,0 +1,53 @@
+"""Under Active Development - INCOMPLETE!"""
+
+# import dashio
+from dashio import quectel_EG800Q
+import time
+import logging
+from dashio.iotcontrol.enums import ConnectionState
+
+
+logging.getLogger('dashio').setLevel(logging.DEBUG)
+
+formatter = logging.Formatter("[%(asctime)s][%(module)15s] -- %(message)s")
+handler = logging.StreamHandler()
+handler.setFormatter(formatter)
+logger = logging.getLogger()
+logger.addHandler(handler)
+logger.setLevel(logging.DEBUG)
+
+
+def _on_mqtt_connect(connected: bool, error_state: quectel_EG800Q.ErrorState):
+    if connected:
+        logger.debug("MQTT connected OK")
+
+        time.sleep(5)  # ???
+        control_topic = "craig/QUECTEL_DEVICE_ID/control"
+        lte.subscribe(control_topic)
+    else:
+        logger.debug("MQTT disconnecting reason  %s", error_state)
+
+
+def _on_mqtt_subscribe(topic: str, error: int):
+    logger.debug("Subscribed: %s %s", topic, str(error))
+
+    announce_topic = "craig/QUECTEL_DEVICE_ID/announce"
+    announce_message = "\tQUECTEL_DEVICE_ID\tWHO\tQuectel_TYPE\tQuectel_Test\n"
+    lte.publish_message(announce_topic, announce_message)
+
+
+def _on_mqtt_receive_message(message: str):
+    try:
+        logger.debug("LTE Rx ←\n%s\n", message.rstrip())
+    except UnicodeDecodeError:
+        logger.debug("LTE SERIAL DECODE ERROR Rx:\n%s\n", message)
+
+
+lte = quectel_EG800Q.EG800Q("/dev/cu.usbmodem1103", "", "iot.gdsp.nz", 115200)
+lte.mqtt_setup("dash.dashio.io", 8883, "craig", "ThingyThing")
+lte.set_callbacks(_on_mqtt_connect, _on_mqtt_subscribe, _on_mqtt_receive_message)
+lte._will_topic = "craig/QUECTEL_DEVICE_ID/data"
+lte.run()
+
+while True:
+    time.sleep(1)

dashio/__init__.py

@@ -75,6 +75,7 @@
 from .schedular import Schedular
 from .tcp_connection import TCPConnection
 from .zmq_connection import ZMQConnection
+from . import quectel_EG800Q
 
 __all__ = [
     'Device',
@@ -144,7 +145,8 @@
     'ButtonGroup',
     'EventData',
     'EventLog',
-    'ColorPicker'
+    'ColorPicker',
+    'quectel_EG800Q'
 ]