miPubSub

Publish/Subscribe pattern build with RabbitMQ and Protocol Buffers

Project description

Publish/Subscribe pattern build with RabbitMQ and Protocol Buffers.

Installation

To install miPubSub, use pipenv (or pip):

$ pipenv install -e git@github.com:azylinski/miPubSub.git@master#egg=miPubSub

Run RabbitMQ

In order to use miPubSub, you need to have access to RabbitMQ server. To setup locally with docker:

docker run -d \
  --name demo-rabbit \
  -p 5672:5672 \
  -p 15672:15672 \
  rabbitmq:3.6.15-management-alpine

Define events structure

# schemas/events/user.proto

syntax = "proto3";

package events;


message User {
  string name = 1;
  string email = 2;
}

# compile proto files
protoc -I=schemas/events/ --python_out=proto/ schemas/events/*.proto

Example

# producer.py

from miPubSub import PubSub
from proto.user_pb2 import User


ps = PubSub('user_management')

u = User(name='Adam West', email='adam.west@mail.com')

ps.publish('signup_completed', u)

# consumer.py

from miPubSub import PubSub
from proto.user_pb2 import User


ps = PubSub('mailer')

@ps.listen('signup_completed', User)
def on_signup_completed(user):
    # Send welcome email to: user.email
    pass

ps.run()