Utilities

Bulk synchronizer without transport

Usage example: it may be used for initial configuration and/or may be used at planned downtime.

On master service:

$ python manage.py cqrs_bulk_dump --cqrs-id=author --output author.dump

On replica service:

$ python manage.py cqrs_bulk_load --input=author.dump

Filter synchronizer over transport

Usage example: sync some specific records to a given replica. Can be used dynamically.

To sync all replicas:

$ python manage.py cqrs_sync --cqrs-id=author --filter="{\"id__in\": [1, 2]}"

To sync all instances only with one replica:

$ python manage.py cqrs_sync --cqrs-id=author --filter="{}" --queue=replica