Skip to content

DSL Reference

DSL Reference

Use the filters below to quickly surface DSL inputs, actions, outputs, categories, and edition availability.

Type Name Categories Edition Summary
ActionAbortControlBothAbort the job if the condition is met.
ActionAddTransformBothAdd fields to the event.
ActionAggregateStateful TransformBothAggregate events by key and emit summary statistics.
ActionAssertValidationBothValidate an event against a JSON Schema, based on IETF's draft v7 (http://json-schema.org).
InputAzure BlobBlock Store CloudEnterprise editionRetrieve (or list) Microsoft Azure Storage blobs (Block Storage).
OutputAzure BlobBlock Store CloudEnterprise editionSend data to a Microsoft Azure Storage blob (Block Storage).
OutputAzure Monitor Data CollectorObservabilityEnterprise editionSpecialized preset that wraps `azure-monitor` output parameters so deployments can ship datasets into Azure Log Analytics/Sentinel without hand-authoring `http-post` jobs.
ActionBatch InTransformBothAccumulate events into batches before downstream processing.
InputBigQueryData WarehouseEnterprise editionIngest data from Google BigQuery.
OutputBigQueryData WarehouseEnterprise editionStream data into Google BigQuery.
ActionBucketTransformBothAssign numeric values to named buckets using ordered thresholds.
ActionChunkText AI & ML TransformBothSegment large payloads into smaller chunks for downstream processing.
InputClickHouseDatabaseEnterprise editionQuery a ClickHouse cluster on a schedule.
OutputClickHouseDatabaseEnterprise editionWrite events to a ClickHouse table using the HTTP interface or native endpoint.
ActionClusterAI & ML TransformBothAssign cluster identifiers to numeric vectors.
ActionConvertTransformBothConvert fields from one type to another, supporting simple and unit conversions Convert fields from one type to another, e.g. strings to numbers.
ActionCopyTransformBothCopy fields of an event using JSONPATH expressions.
ActionCsvTransformBothParse CSV from field text.
ActionDeltaStateful TransformBothConvenience wrapper that enables `stream` delta mode with a slim option set.
OutputDiscardDebugBothDiscard any output from the job.
ActionDocx to TextTransformBothExtract content from Microsoft Word documents with optional image emission.
InputEchoUtilityBothCreate a simple static event.
OutputElasticsearchSearchEnterprise editionBulk-index events into Elasticsearch clusters.
ActionEnrichEnrichmentBothLook up values in a CSV or Sqlite database and add matching fields.
InputExecUtilityBothObtain data by executing a shell command.
ActionExpandTransformBothexpand data in various ways: events, XML, multiline events.
ActionExpand EventsTransformBothexpand a single JSON document into multiple JSON events.
ActionExtractTransformBothExtract fields from text using regular expressions.
InputFacebook Graph PollFacebookEnterprise editionOpinionated preset for polling Facebook Graph posts with cursor pagination and AI-prep ready defaults.
InputFile StoreBlock Store FileBothRead from a local file system object store.
OutputFile StoreBlock Store FileBothWrite to a local file system object store.
ActionFilterTransformBothOnly let certain events pass through.
ActionFlattenTransformBothFlatten nested JSON Objects and Arrays into a single JSON Object containing only top-level fields.
InputFTPFile UtilityEnterprise editionPoll remote FTP/SFTP/TFTP servers for new files.
OutputFTPFile UtilityEnterprise editionUpload events to FTP/SFTP/TFTP servers.
InputGoogle Cloud StorageBlock Store CloudEnterprise editionRead objects from Google Cloud Storage.
OutputGoogle Cloud StorageBlock Store CloudEnterprise editionWrite events to a Google Cloud bucket.
OutputHTTP GetHttpBothSend event data to a remote server using GET.
InputHTTP PollHttpBothRun HTTP queries.
OutputHTTP PostHttpBothPOST event data to an HTTPS server.
InputHTTP ServerHttpBothRun an HTTP server and output any received requests.
ActionInferAI & MLEnterprise editionExecute inference workloads (LLM, embeddings, anomaly detection).
InputInternal MessagesMessagingBothReceive internal messages.
ActionJava ScriptTransform ScriptingEnterprise editionExecute embedded JavaScript to transform events.
InputJournaldLinuxEnterprise editionRead events from systemd-journald (Linux-only).
ActionJsonTransformBothParse text as JSON.
InputKafkaMessagingEnterprise editionConsume records from Kafka/Redpanda clusters.
OutputKafkaMessagingEnterprise editionPublish events to Kafka/Redpanda clusters.
ActionKey ValueTransformBothParse key-value pairs, like "k1=v1,k2=v2,....".
ActionLabel MapTransformBothMap string values to canonical labels using ordered rules.
OutputLog FilesFileBothAppend events to one or more files.
InputLog FilesFileBothMonitor one or more log files for new lines.
ActionMarkdown OutlineText AI & ML TransformBothParse Markdown documents into structured outline data.
ActionMessageMessagingBothConditionally generate a message when an event meets the provided condition.
OutputMessageMessagingBothCreate a message to the internal message subsystem.
InputMicrosoft GraphAPI MicrosoftEnterprise editionIngest data from Microsoft Graph resources such as mail, calendars, or directory objects via REST calls.
InputMongoDBDatabaseEnterprise editionRead MongoDB documents via scheduled `find` or `aggregate` queries.
OutputMongoDBDatabaseEnterprise editionWrite events to MongoDB collections.
InputMQTTMessagingEnterprise editionIngest events from MQTT brokers (client mode) or an embedded broker (broker mode).
OutputMQTTMessagingEnterprise editionPublish events to external MQTT brokers or an embedded broker instance.
InputMySQLDatabaseEnterprise editionQuery MySQL databases or stream change data capture events.
OutputMySQLDatabaseEnterprise editionExecute parameterised statements against MySQL databases.
InputODBC SQLDatabaseEnterprise editionQuery relational databases over ODBC or stream change data capture events.
OutputODBC SQLDatabaseEnterprise editionExecute parameterised statements against relational databases over ODBC.
OutputOpenSearchSearchEnterprise editionBulk-index events into OpenSearch clusters, including AWS-managed variants.
InputOpenTelemetryObservabilityEnterprise editionAccept OpenTelemetry OTLP signals over gRPC.
OutputOpenTelemetryObservabilityEnterprise editionExport events using the OpenTelemetry OTLP protocol.
ActionPDF to TextTransformBothExtract text content from PDF documents using auto or render-based strategies.
InputPostgreSQLDatabaseEnterprise editionQuery PostgreSQL databases or stream change data capture events.
OutputPostgreSQLDatabaseEnterprise editionExecute parameterised statements against PostgreSQL databases.
ActionPrintDebugBothPrint event payloads to the terminal.
OutputPrintDebugBothPrint event payloads to the terminal.
ActionRemoveTransformBothRemove fields from an event.
ActionRenameTransformBothRename event fields.
InputS3Block Store CloudEnterprise editionStream data from an S3 object.
OutputS3Block Store CloudEnterprise editionWrite events to an S3 bucket.
ActionScoringAnalyticsBothEvaluate weighted conditions to produce a composite score.
ActionScriptTransform ScriptingEnterprise editionCalculated fields.
ActionSlugifyTransformBothGenerate stable slugs from one or more fields.
OutputSplunk HECObservabilityEnterprise editionOutput events to a Splunk HTTP Event Collector endpoint (Splunk HEC).
InputSQL ServerDatabaseEnterprise editionQuery Microsoft SQL Server databases.
OutputSQL ServerDatabaseEnterprise editionExecute parameterised statements against Microsoft SQL Server databases.
ActionStalledStateful TransformBothEmit stall markers when no matching events arrive within the configured timeout.
ActionStop WordText AI & ML TransformBothRemove or mask common stop words from textual content.
ActionStreamStateful TransformBothTrack per-key changes and emit deltas, elapsed times, and optional aggregates.
OutputSyslogObservabilityEnterprise editionEmit events as syslog messages to remote or local syslog receivers. Supported endpoint schemes: - `udp://host:port` - `tcp://host:port` - `tls://host:port` - `unix:///path` (unix stream) - `unixgram:///path` (unix datagram).
ActionTimeTransformBothTime processing: parsing and formatting time values.
ActionTokenizeText AI & ML TransformBothConvert free-form text into token sequences for downstream analytics.
ActionTransactionStateful TransformBothSessionize related events using start/end markers and optional summary fields.
ActionTransitionStateful TransformBothTrack field transitions, elapsed time since last change, and optional state metadata.
InputTriggerSchedulerBothManaged trigger input that emits scheduler messages with optional Worker KV leadership.
ActionUnbatchTransformBothExpand a batched event back into individual events.
InputWeb Dav StoreBlock Store WebDAVEnterprise editionRead from a WebDAV-compatible object store.
OutputWeb Dav StoreBlock Store WebDAVEnterprise editionWrite to a WebDAV-compatible object store.
InputWebSocketMessagingEnterprise editionConsume events from remote WebSocket endpoints.
OutputWebSocketMessagingEnterprise editionSend events to remote WebSocket peers or expose an embedded server.
InputWindows Event LogWindowsEnterprise editionRead events from Windows Event Log.
InputWorker ChannelMessagingBothReceive events from a worker managed channel.
OutputWorker ChannelMessagingBothReceive events from a worker managed channel.
InputWorker KVStorageBothInteract with the deployments-managed Worker KV store.
OutputWorker KVStorageBothMutate the deployments-managed Worker KV store.
ActionWorker KV (Mutate)StorageBothMutate the deployments-managed Worker KV store.
ActionWorker KV GetStorageBothFetch a single Worker KV value and write it into an event field.
ActionXLSX ExpandTransformBothExpand Microsoft Excel worksheets into individual events or CSV-like structures.
ActionXmlTransformBothexpand XML into JSON events.