AWS wrapper around IPC
Project description
bluenav-ipc-thread
Un package python à utiliser dans un environement d'éxécution GreengrassCoreV2
Ce package permet d'encapsuler l'API IPC de Greengrass afin de l'utiliser simplement pour échanger des données entre les différents processus ou envoyer des messages MQTT vers AWS IOT Core
Installation
```bash pip install git+https://bitbucket.org/bluenav/bluenav-ipc-thread/src/master/ ```
API
```Python import threading from ipc_thread import IPCThread from queue import Queue
sub_queue = Queue() pub_queue = Queue() sub_core_queue = Queue() pub_core_queue = Queue()
Publier des messages dans un contexte local, dès qu'un message arrive dans la pub_queue il est extrait et envoyé automatiquement
Le message doit être un dict contenant une clé topic et une clé message
threading.Thread(target=IPCThread.IPCThreadPublish,args=(pub_queue, )).start() pub_queue.put({"topic": "navigation/CourseOverGround", "message": {"value": 2.765, "unit": "m/s", "PGN": 129026, "SID": 14, "timestamp": 1654847536}})
Souscrire à un topic dans un contexte local afin de recevoir tous les messages transitants sur ce topic dans la sub_queue
IPCThread.IPCThreadSubscribe(sub_queue, ["navigation/CourseOverGround", ...])
Pour le même fonctionnement mais dans un contexte distant (IoT Core <-> Machine locale) utiliser:
IPCThread.IPCThreadPublishToCore, IPCThread.IPCThreadSubscribeToCore
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for bluenav_ipc_thread-0.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 9b2b6977af021cde095267cfba5b7f52fe562dc6e79fbc7b27b3ad9aeb04f5e3 |
|
MD5 | 78855daca2057111dcf226cc48bf69ad |
|
BLAKE2b-256 | 6045c76fac5c89475025642643b3858964df88b9d8d9f6f74adb7f4cfa2aa2ae |