Trigger a function

Triggering a function means that you invoke a function by producing a message to one of the input topics via the CLI. You can use the trigger command to trigger a function at any time.

Trigger a function - 图1tip

With the pulsar-admin CLI, you can send messages to functions without using the pulsar-client tool or a language-specific client library.

To learn how to trigger a function, you can start with a Python function that returns a simple string based on the input as follows.

  1. # myfunc.py
  2. def process(input):
  3.     return "This function has been triggered with a value of {0}".format(input)
  1. Run the function in cluster mode.
  1. bin/pulsar-admin functions create \
  2.   --tenant public \
  3.   --namespace default \
  4.   --name myfunc \
  5.   --py myfunc.py \
  6.   --classname myfunc \
  7.   --inputs persistent://public/default/in \
  8.   --output persistent://public/default/out
  1. Assign a consumer to listen on the output topic for messages from the myfunc function with the pulsar-client consume command.
  1. bin/pulsar-client consume persistent://public/default/out \
  2.   --subscription-name my-subscription \
  3.   --num-messages 0 # Listen indefinitely

  1. Trigger the function.

    1. bin/pulsar-admin functions trigger \
    2.   --tenant public \
    3.   --namespace default \
    4.   --name myfunc \
    5.   --trigger-value "hello world"

    Trigger a function - 图2tip

    In the trigger command, topic info is not required. You only need to specify basic information about the function, such as tenant, namespace, and function name.

The consumer listening on the output topic produces something as follows in the log.

  1. ----- got message -----
  2. This function has been triggered with a value of hello world