Processors
Processors transform, validate, or route messages within a pipeline. They are applied in order between the input and output. Add processors when creating or editing a flow in the UI.
| Component | Description |
|---|---|
| AI Gateway | Calls an AI chat completion API (OpenAI, Anthropic) |
| NLP Extract Features | Embed text with an ONNX feature extraction model |
| NLP Classify Text | Classify text with an ONNX classifier |
| NLP Classify Tokens | Extract named entities or other token-level labels |
| NLP Zero-Shot Classify | Classify text into arbitrary labels at runtime using an NLI model |
| Google Calendar | Google Calendar operations (events, calendars, availability) |
| Google Drive | Google Drive operations (files, folders, permissions, shared drives) |
| Google Sheets | Google Sheets operations (spreadsheets, worksheets, rows, formatting) |
| Shopify | Shopify Admin API operations (orders, products, customers, inventory) |
| Mapping | Bloblang transformations |
| Command | Executes an external command, piping the message through stdin/stdout |
| Python | Runs a Python script for each message in a sandboxed WASM runtime |
| JSON Schema | Validates messages against a JSON schema |
| Catch | Error handling — runs processors on failure |
| Switch | Conditional processing based on message content |
| Schema Registry Decode | Decodes Avro messages via Schema Registry |
| HTTP Client | Sends a message as an HTTP request and replaces it with the response |
| SQL Raw | Runs an arbitrary SQL query against a database |
| SQL Select | Runs a SELECT query and replaces the message with the rows returned |
| SQL Insert | Inserts a row into an SQL database for each message |