fastiot_sample_services.redis_producer package

Example Redis Producer

Redis Producer gives an example on how to interact with fastiot.db.redis_helper.RedisHelper. It saves fastiot.msg.thing.Thing objects via the fastiot.db.redis_helper.RedisHelper and publishes the message under fastiot.msg.redis.RedisMsg. It also listens to messages published under Redis.>. and gets the corresponding Data from fastiot.db.redis_helper.RedisHelper.

Submodules

fastiot_sample_services.redis_producer.redis_producer_module module

class fastiot_sample_services.redis_producer.redis_producer_module.ExampleRedisProducerService(broker_connection, **kwargs)

async produce()

async consume(msg)

fastiot_sample_services.redis_producer.run module