Small Fedora-messaging triggered programs that we want to keep running around
Find a file
Nils Philippsen faca6e5521 CI: Fix running tox via Zuul
Signed-off-by: Nils Philippsen <nils@redhat.com>
2020-06-29 14:20:03 +02:00
tests Make the tests flake8 valid and enforce it in tox 2020-06-26 15:18:09 +00:00
toddlers Introduce playtime 2020-06-26 16:29:52 +02:00
.gitignore Add a tox.ini file and ignore the generated .tox folder 2020-06-19 17:12:51 +02:00
.zuul.yaml CI: Fix running tox via Zuul 2020-06-29 14:20:03 +02:00
bindep.txt CI: Fix running tox via Zuul 2020-06-29 14:20:03 +02:00
Dockerfile Install fedora-messaging in the container 2020-06-24 17:36:04 +02:00
LICENSE Add a LICENSE file 2020-06-12 16:15:25 +02:00
README.rst Fix typo 2020-06-26 16:52:41 +02:00
requirements.txt Add requirements 2020-06-26 16:52:41 +02:00
setup.cfg Add a tox.ini file and ignore the generated .tox folder 2020-06-19 17:12:51 +02:00
test-requirements.txt Add requirements 2020-06-26 16:52:41 +02:00
toddlers.toml.example Let each toddler have their own section in the configuration file 2020-06-18 10:47:56 +02:00
tox.ini Make the tests flake8 valid and enforce it in tox 2020-06-26 15:18:09 +00:00

Toddlers
========

Toddlers is a simple application aimed at running tasks upon fedora-messaging
notifications.

In other words, it's a bunch of small programs that keeps running around.


How does it work?
-----------------

It is a `fedora-messaging <https://fedora-messaging.readthedocs.io/>`_ consumer
that listens for a number of topics defined by each toddler.

The runner will then asks each toddler if they are interested by the topic of
the message it just received and if so, it will send the full message to the
toddler to be processed.


How can I add a toddler?
------------------------

Toddlers need to be a subclass of ``toddlers.base.ToddlerBase`` (see the file
``toddlers/base.py``), it needs to have the 2 required property and the 2
required methods and needs to be in the folder: ``toddlers/plugins/`` from which
it will be automatically loaded.


What happens if a toddler trips and fails to process a message?
---------------------------------------------------------------

If a toddler fails to process a message (ie: it raises an exception)
the message is put back in the queue and will be processed later.
Depending on the order in which the toddler are run, it is possible that a
toddler sees multiple times the same message, the code should thus take this
into account and check if it needs to do something before doing it.

If none of the toddlers raised an exception the message is considered as
processed.


How does it scale?
------------------

Toddlers consumes queues that are created for it in rabbitmq, so you can start
as many processes as you like, rabbitmq will distribute the message in the queue
in a round robin fashion to each consumers, allowing you to easily scale up or
down depending on your load and needs.


How to run it locally?
----------------------

Follow these simples steps:

* Install the dependencies:

::

    dnf install python3-requests python3-koji fedora-messaging

* Clone locally this repository and go into it:

::

    git clone https://pagure.io/fedora-infra/toddlers.git
    cd toddlers

* Adjust the example configuration file so it creates a temporary queue just for
  you

::

    sed -e "s/[0-9a-f]\{8\}-[0-9a-f]\{4\}-[0-9a-f]\{4\}-[0-9a-f]\{4\}-[0-9a-f]\{12\}/$(uuidgen)/g" \
    toddlers.toml.example > toddlers.toml

* Run the consumer:

::

    PYTHONPATH=. fedora-messaging --conf=toddlers.toml consume

.. warning:: If you are adding a toddler to be run in the Fedora infrastructure
   and this toddler needs to listen to a new topic, you will have to add it
   to the ansible playbook for toddlers, the dynamic loading of the topics that
   toddlers has works for local development but will not work in production.
   The ansible playbook is at: https://pagure.io/fedora-infra/ansible/blob/master/f/playbooks/openshift-apps/toddlers.yml


How to run the tests?
---------------------

* Simply install:

::

    dnf install python3-tox

* And run the tests:

::

    tox tests/