Python sink
Along with the included pre-made agents, you can provide your own custom sink agent as a Python application.
The Python application needs to follow a specific directory structure for this agent to successfully run.
Within the “application” directory, create a directory named “python”.
Within that directory, place the .py file with the class that will be the entry point.
The directory will look like this:
For more on developing custom Python sink agents, see the Agent Developer Guide.
Python sink example
Configure the agent to use the python class in pipeline.yaml:
Topics
Input
Output
None, it’s a sink.
Configuration
className
String (required)
A combination of the file name and the class name.
Example: For the file my-python-app.py that has class MySink, the value would be my-python-app.MySink
<any>
Additional configuration properties specific to the application.
Last updated