py-rodo 0.0.1

Helper library to process messages on rabbit.opensuse.org

This is a small helper library to process messages emitted to rabbit.opensuse.org by the Open Build Service.

Usage

Warning

This library is experimental and is the product of trial & error experimentation. Proceed with caution.

The main entry point for this library is the QueueProcessor class, which listens to the message bus, processes messages and invokes user defined callbacks depending on the message routing keys.

The message callback functions receive a child class of ObsMessageBusPayloadBase as the single argument and should return nothing. The specific subtype of ObsMessageBusPayloadBase can be infered from the dictionary QUEUE_TO_PAYLOAD_TYPE which maps the routing keys to specific payload types.

To only process package commit messages, create the following callback:

def commit_to_my_package(payload: PackageCommitPayload) -> None:
    # process the payload here

callbacks = {RoutingKey.PACKAGE_COMMIT: commit_to_my_package}

qp = QueueProcessor(callbacks=callbacks)
qp.listen_forever()