Tool for agent ecosystem
Project description
The goal of this project is to facilitate the creation of microservices interacting via a signal bus and/or queue broker.
The philosophy of this project is to present a microservice as a software agent that directly interacts only with queues and the event bus, and not with other microservices.
Tool is intended for developing:
distributed apps with event-driven architecture
distributed apps with data-driven architecture
multi-processors apps
Tool provide features:
running a periodical tasks (interval or as CRON)
specification of signals (events), their sending and receiving via the bus (aioredis)
description of queues, sending and receiving messages via the queue broker (aioamqp, kafka, aioredis)
limited RPC via signal bus
launching sub-services (in the same process)
launching a group of microagents (each in a separate process)
mocks for bus and broker
See MicroAgent documentation.
class Agent(MicroAgent):
@on('pre_start')
async def setup(self):
pass # init connections to DB, REDIS, SMTP and other services
@periodic(period=5)
async def refresh_cache(self):
pass # do something periodicly
@cron('0 */4 * * *')
async def send_report(self):
pass # do something by schedule
# subscribe to signals (events)
@receiver(signals.user_updated, signals.user_deleted)
async def send_notification(self, **kwargs):
# send signal (event) to bus
await self.bus.check_something.send(sender='agent', **kwargs)
# message consumer from queue
@consumer(queues.mailer)
async def send_emails(self, **kwargs):
# send message to queue
await self.broker.statistic_collector.send(kwargs)
async def main():
bus = AIORedisSignalBus('redis://localhost/7')
broker = AIORedisBroker('redis://localhost/7')
# usage bus and broker separate from agent
await bus.started.send('user_agent')
await broker.mailer(data)
agent = Agent(bus=bus, broker=broker)
await agent.start()
Installing
With aioredis backend provide signal bus and list-based queues:
pip install 'microagent[aioredis]'
With aioamqp backend provide queues over AMQP (RabbitMQ):
pip install 'microagent[amqp]'
With kafka backend provide queues over Kafka (experemental):
pip install 'microagent[kafka]'
Project details
Release history Release notifications | RSS feed
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 microagent-1.6b3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 63deaa2e05e54f30a98887e3560b1040f6b2376752dce268dba83be6a334a312 |
|
MD5 | 7b9c4ff4fda51185d2089787b74eb160 |
|
BLAKE2b-256 | 5bd9b6cbc00709d1d54d032f35d46a602298359797fcada7e3cf6567dc2f2fe8 |