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.

See also

fastiot.db.redis_helper.RedisHelper: How to easily interact using the integrated RedisHelper.
fastiot.cli.common.infrastructure_services.RedisService: The infrastructure service definition for the Redis Server.
fastiot_sample_services.redis_producer: Example service for sending and receiving data over a Redis Server.

Submodules

fastiot_sample_services.redis_producer.redis_producer_module module

class fastiot_sample_services.redis_producer.redis_producer_module.ExampleRedisProducerService(broker_connection=None, **kwargs)[source]

async produce()[source]

async consume(msg)[source]

fastiot_sample_services.redis_producer.run module