amqp-client-python 0.1.4

No project description provided

AMQP Client Python

---

Client with high level of abstraction for manipulation of messages in the event bus RabbitMQ.

Features:

• Automatic creation and management of queues, exchanges and channels;
• Support for direct, topic and fanout exchanges;
• Publish;
• Subscribe;
• Support for a Remote procedure call (RPC).

Examples:

• basic usage

  # basic configuration
  from amqp_client_python import (
      AsyncEventbusRabbitMQ,
      Config, Options
  )
  from amqp_client_python.event import IntegrationEvent, IntegrationEventHandler
  config = Config(Options("queue", "rpc_queue", "rpc_exchange"))
  eventbus = AsyncEventbusRabbitMQ(config)
  # publish
  class ExampleEvent(IntegrationEvent):
      EVENT_NAME: str = "ExampleEvent"
      def __init__(self, event_type: str, message = []) -> None:
          super().__init__(self.EVENT_NAME, event_type)
          self.message = message
  
  publish_event = ExampleEvent(rpc_exchange, ["message"])
  eventbus.publish(publish_event, rpc_routing_key, "direct")
  # subscribe
  class ExampleEventHandler(IntegrationEventHandler):
      def handle(self, body) -> None:
          print(body) # handle messages
  await eventbus.subscribe(subscribe_event, subscribe_event_handle, rpc_routing_key)
  # rpc_publish
  response = await eventbus.rpc_client(rpc_exchange, "user.find", ["content_message"])
  # provider
  async def handle2(*body) -> bytes:
      print(f"body: {body}")
      return b"content"
  await eventbus.provide_resource("user.find", handle)