A MicroPython client for NATS.io.
Note: Socket KeepAlive Option is not available as of now,will be added once the feature is available in MicroPython.
Thanks to @mcuadros - pynats being ported to Micropython with minor changes
- MicroPython ~1.8.6
- gnatsd server
- Any MicroPython supported PyBoard - As of now tested on PyCom Chips running on ESP32
c = mpynats.Connection(verbose=True)
c.connect()
# Simple Publisher
c.publish('foo', 'Hello World!')
# Simple Subscriber
def callback(msg):
print 'Received a message: %s' % msg.data
c.subscribe('foo', callback)
# Waiting for one msg
c.wait(count=1)
# Requests
def request_callback(msg):
print 'Got a response for help: %s' % msg.data
c.request('help', request_callback)
c.wait(count=1)
# Unsubscribing
subscription = c.subscribe('foo', callback)
c.unsubscribe(subscription)
# Close connection
c.close()import machine
from network import WLAN #Pycom Library
import mpynats
wlan = WLAN(mode=WLAN.STA)
wlan.connect('Test', auth=(WLAN.WPA2, 'booboo@123'), timeout=5000)
while not wlan.isconnected():
machine.idle() # save power while waiting
break
if wlan.isconnected():
c = mpynats.Connection('nats:https://192.168.1.4:4222', 'swift', False, True, False, False, False, True)
c.connect()
print("Nats Server Connected!!!")
c.publish('foo', 'HelloWorld')
MIT, see LICENSE