Documentation

Installation and deployment

Examples

Triggerflow Client Example

fromtriggerflowimportTriggerflow,CloudEvent,DefaultConditionsfromtriggerflow.functionsimportPythonCallablefromtriggerflow.eventsources.rabbitimportRabbitMQEventSource# Instantiate Triggerflow clienttf_client=Triggerflow()# Create a workspace and add a RabbitMQ event source to itrabbitmq_source=RabbitMQEventSource(amqp_url='amqp://guest:guest@172.17.0.3/',queue='My-Queue')tf_client.create_workspace(workspace_name='test',event_source=rabbitmq_source)defmy_action(context,event):context['message']+='World!'# Create the trigger activation eventactivation_event=CloudEvent().SetEventType('test.event.type').SetSubject('Test')# Create a trigger with a custom Python callable action and a Join condition that joins 10 eventstf_client.add_trigger(trigger_id='MyTrigger',event=activation_event,condition=DefaultConditions.JOIN,action=PythonCallable(my_action),context={'message':'Hello ','join':10})# Publish 10 activation events, the action will only be executed on the 10th eventfor_inrange(10):rabbitmq_source.publish_cloudevent(activation_event)# Retrieve the trigger's contexttrg=tf_client.get_trigger('MyTrigger')print(trg['context']['message'])# Prints 'Hello World!'