hello_world.py

import time
from triggerflow import Triggerflow, CloudEvent
from triggerflow.functions import PythonCallable
from triggerflow.eventsources.rabbit import RabbitMQEventSource

tf_client = Triggerflow(endpoint='${TRIGGERFLOW_ENDPOINT}', user='admin', password='admin')

rabbitmq_source = RabbitMQEventSource(amqp_url='amqp://guest:guest@${RABBITMQ_BROKER}/', queue='My-Queue')

tf_client.create_workspace(workspace_name='test', event_source=rabbitmq_source)


def my_action(context, event):
    context['message'] += 'World!'


activation_event = CloudEvent().SetEventType('test.event.type').SetSubject('Test')

tf_client.add_trigger(trigger_id='MyTrigger',
                      event=activation_event,
                      action=PythonCallable(my_action),
                      context={'message': 'Hello '})

rabbitmq_source.publish_cloudevent(activation_event)

time.sleep(3)  # Let some time for the DB to be updated

trg = tf_client.get_trigger('MyTrigger')
print(trg['context']['message'])