Subscribe to live topic messages
subscribe_live_topicsConnect to a live data stream, subscribe to topics, and store messages locally for later analysis or pipeline execution.
Instructions
Use this tool to connect to a live data stream and subscribe to one or more topics. Messages are written to a local sink directory, which can be used later as input for other tools (via the path argument in SourceFactory). Optionally attach a pipeline config to create a STANDING pipeline that runs on incoming messages -- e.g. an on_event cadence that captures and uploads a window around every anomaly.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| args | No | ||
| host | No | ||
| port | No | ||
| type_ | Yes | ||
| topics | No | ||
| pipeline | No | ||
| overwrite | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |