Redis

$ pip install petisco[redis]
---> 100%
Successfully installed petisco

This page is an overview of how petisco helps us on Message Broker development using Redis as message publishers.

RedisDomainEventBus

The RedisDomainEventBus saves with LPUSH published events.

Example

from petisco.extra.redis import RedisDomainEventBus
from redis.client import Redis    

organization = "acme"
service = "petisco"
redis = Redis()

domain_event_bus = RedisDomainEventBus(organization, service, redis)

RedisCommandsBus

The RedisCommandBus saves with LPUSH dispatched commands.

Example

from petisco.extra.redis import RedisCommandBus
from redis.client import Redis    

organization = "acme"
service = "petisco"
redis = Redis()

command_bus = RedisCommandBus(organization, service, redis)

Working as a fallback of RabbitMQ

This Redis implementation could be very interesting to work as a fallback of RabbitMQ implementation. This helps to make the system more reliable by saving in Redis the messages that rabbitmq cannot publish.

flowchart TD
    rabbitmq

  RabbitMqDomainEventBus --> fallback_domain_event

    RabbitMqCommandBus --> fallback_command

    RabbitMqDomainEventBus -..-> rabbitmq
    RabbitMqCommandBus -..-> rabbitmq


    subgraph fallback_domain_event[fallback]
    RedisDomainEventBus
    end

    subgraph fallback_command[fallback]
    RedisCommandBus
    end

    subgraph redis
    domain.events
    commands
    end

    RedisDomainEventBus --> domain.events
    RedisCommandBus --> commands

    cronjob(cronjob)
    domain.events -..-> cronjob
    commands -..-> cronjob

    cronjob -. republish/dispatch .-> rabbitmq

Example

from petisco.extra.rabbitmq import RabbitMqDomainEventBus, RabbitMqCommandBus
from petisco.extra.redis import RedisDomainEventBus, RedisCommandBus
from redis.client import Redis    

organization = "acme"
service = "petisco"

# Redis
redis = Redis()
fallback_domain_event_bus = RedisDomainEventBus(organization, service, redis)
fallback_command_bus = RedisCommandBus(organization, service, redis)

# RabbitMq
rabbitmq_connector = RabbitMqConnector()
domain_event_bus = RabbitMqDomainEventBus(organization, service, rabbitmq_connector, fallback=fallback_domain_event_bus)
command_bus = RabbitMqCommandBus(organization, service, rabbitmq_connector, fallback=fallback_command_bus)