ESC
All(0)
emoticon icon

No results found for the current search

Kestra AIAsk Kestra AI
ESC
Kestra AI

Hi! I'm your Kestra AI assistant.
Ask me anything about workflows.

EXAMPLE QUESTIONS

  1. ✨ Kestra 1.1 is here with Better UI, Smarter AI and Enterprise Control 🚀 Learn More

Item 1 of 1
Kestra, Open source declarative data orchestration
  • Product
    • Core Features
    • Enterprise Edition
    • Cloud EditionRequest Access
  • Solutions

      Capabilities

    • Declarative Orchestration
    • Automation Platform
    • Language Agnostic
    • Kestra's Terraform Provider
    • API-First
    • Platform Overview

      By Roles

    • Data Engineers
    • Software Engineers
    • Platform Engineers

      By Industries

    • Retail & Supply Chain
    • Healthcare & Pharmaceuticals
    • Automotive & Heavy Equipment
    • All use-cases

      Resources

    • About Us
    • Partner
    • FAQ
    • Community Overview
    • Community Contents
    • Customer Stories
    • Changelog
  • Learn
    • Docs
    • Blog
    • Blueprints
    • Video Tutorials
    • How to guides
    • Why kestra
    • Quickstart installation guide.
  • Plugins
  • Pricing
  • Star
    Talk to us Get Started! Talk to Us
  • Core Features

    Explore Kestra's Core Capabilities

  • Enterprise Edition

    Security and Governance for Enterprise Needs

  • Cloud EditionRequest Access

    the Cloud edition managed by Kestra

Capabilities

  • Declarative Orchestration

    Infrastructure as Code of All Your Workflows

  • Automation Platform

    Scheduling and Automation Made Easy

  • Language Agnostic

    Orchestrate business logic in any language

  • Kestra's Terraform Provider

    Deploy & manage all resources with Terraform

  • API-First

    Learn more about Kestra's API features

  • Platform Overview

    Powerful Capabilities from the UI

By Roles

  • Data Engineers
  • Software Engineers
  • Platform Engineers

By Industries

  • Retail & Supply Chain
  • Healthcare & Pharmaceuticals
  • Automotive & Heavy Equipment
  • All use-cases

Resources

  • About Us
  • Partner
  • FAQ
  • Community Overview
  • Community Contents
  • Customer Stories
  • Changelog
  • Docs

    Everything Kestra

  • Blog

    Tutorials, Guides, Market Trends and More

  • Blueprints

    A Library of ready to use Workflows

  • Video Tutorials

    your favourite tutorials in video

  • How to guides

    Learn step by step how to address use-cases

  • Why kestra

    Trust kestra as your unified orchestration tool

  • Quickstart installation guide.

    Trust kestra as your unified orchestration tool

Search

Ctrl + K
  • Core
    • Debug
      • Tasks
        • Return
    • KV
      • Tasks
        • Delete
        • Get
        • GetKeys
        • PurgeKV
        • Set
    • Output
      • Tasks
        • OutputValues
    • Chart
      • Charts
        • Bar
        • KPI
        • Markdown
        • Pie
        • Table
        • TimeSeries
    • Execution App Block
      • App Blocks
        • CancelExecutionButton
        • CreateExecutionButton
        • CreateExecutionForm
        • DownloadLogsButton
        • Inputs
        • Logs
        • Outputs
        • ResumeExecutionButton
        • ResumeExecutionForm
        • TaskOutputs
    • Log
      • Tasks
        • Fetch
        • Log
        • PurgeLogs
    • Runner
      • Task Runners
        • Process
    • Condition
      • Conditions
        • DateTimeBetween
        • DayWeek
        • DayWeekInMonth
        • ExecutionFlow
        • ExecutionLabels
        • ExecutionNamespace
        • ExecutionOutputs
        • ExecutionStatus
        • Expression
        • HasRetryAttempt
        • Not
        • Or
        • PublicHoliday
        • TimeBetween
        • Weekend
    • Trigger
      • Tasks
        • Toggle
      • Triggers
        • Flow
        • Schedule
        • ScheduleOnDates
        • Webhook
    • Core App Block
      • App Blocks
        • Alert
        • AutoRefresh
        • Button
        • Divider
        • Image
        • Loading
        • Markdown
        • RedirectTo
        • Stacktrace
        • Table
    • Flow
      • Tasks
        • AllowFailure
        • Dag
        • ForEach
        • ForEachItem
        • If
        • LoopUntil
        • Parallel
        • Pause
        • Sequential
        • Sleep
        • Subflow
        • Switch
        • WorkingDirectory
    • App
      • Apps
        • Execution
    • Data Filter
      • Data Filters
        • Executions
        • Flows
        • Logs
        • Metrics
        • Triggers
      • Data FiltersKPI
        • ExecutionsKPI
        • FlowsKPI
        • LogsKPI
        • MetricsKPI
    • Namespace
      • Tasks
        • DeleteFiles
        • DownloadFiles
        • UploadFiles
    • HTTP
      • Tasks
        • Download
        • Request
      • Triggers
        • Trigger
    • Templating
      • Tasks
        • TemplatedTask
    • Log (EE)
      • Tasks
        • AuditLogShipper
        • LogShipper
        • PurgeAuditLogs
      • Log Exporters
        • FileLogExporter
    • Docker
      • Task Runners
        • Docker
    • Execution
      • Tasks
        • Assert
        • Count
        • Exit
        • Fail
        • Labels
        • PurgeExecutions
        • Resume
        • SetVariables
        • UnsetVariables
    • Storage
      • Tasks
        • Concat
        • DeduplicateItems
        • Delete
        • FilterItems
        • PurgeCurrentExecutionFiles
        • Reverse
        • Size
        • Split
        • Write
  • Actian Vector
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • AI
    • Agent
      • Tasks
        • A2AClient
        • AIAgent
    • Tool
      • Additional Plugins
        • A2AClient
        • AIAgent
        • CodeExecution
        • DockerMcpClient
        • GoogleCustomWebSearch
        • KestraFlow
        • KestraTask
        • SseMcpClient
        • StdioMcpClient
        • StreamableHttpMcpClient
        • TavilyWebSearch
    • Embeddings
      • Additional Plugins
        • Chroma
        • Elasticsearch
        • KestraKVStore
        • MariaDB
        • Milvus
        • MongoDBAtlas
        • PGVector
        • Pinecone
        • Qdrant
        • Redis
        • Tablestore
        • Weaviate
    • Provider
      • Additional Plugins
        • AmazonBedrock
        • Anthropic
        • AzureOpenAI
        • DashScope
        • DeepSeek
        • GoogleGemini
        • GoogleVertexAI
        • HuggingFace
        • LocalAI
        • MistralAI
        • OciGenAI
        • Ollama
        • OpenAI
        • OpenRouter
        • WorkersAI
        • ZhiPuAI
    • RAG
      • Tasks
        • ChatCompletion
        • IngestDocument
        • Search
    • Memory
      • Additional Plugins
        • KestraKVStore
        • PostgreSQL
        • Redis
    • Retriever
      • Additional Plugins
        • GoogleCustomWebSearch
        • SqlDatabaseRetriever
        • TavilyWebSearch
    • Completion
      • Tasks
        • ChatCompletion
        • Classification
        • ImageGeneration
        • JSONStructuredExtraction
  • Airbyte
    • Jobs
      • Tasks
        • Reset
        • Sync
    • Connections
      • Tasks
        • CheckStatus
        • Sync
  • Airflow
    • Dags
      • Tasks
        • TriggerDagRun
  • Airtable
    • Airtable Record
      • Tasks
        • Create
        • Delete
        • Get
        • List
        • Update
  • Algolia
    • Tasks
      • Delete
      • Index
      • Search
  • Amazon Redshift
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • AMQP
    • Tasks
      • Consume
      • CreateQueue
      • DeclareExchange
      • Publish
      • QueueBind
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Ansible
    • Tasks
      • AnsibleCLI
  • Anthropic
    • Tasks
      • ChatCompletion
  • Apache Cassandra
    • Astradb
      • Tasks
        • Query
      • Triggers
        • Trigger
    • Standard
      • Tasks
        • Query
      • Triggers
        • Trigger
  • Apache Druid
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Apache Flink
    • Tasks
      • CancelJob
      • Submit
      • SubmitSql
      • TriggerSavepoint
    • Triggers
      • MonitorJob
  • Apache Kafka
    • Tasks
      • Consume
      • Produce
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Apache Pinot
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Apache Pulsar
    • Tasks
      • Consume
      • Produce
      • Reader
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Apache Spark
    • Tasks
      • JarSubmit
      • PythonSubmit
      • RSubmit
      • SparkCLI
  • Apache Tika
    • Tasks
      • Parse
  • Apify
    • Apify Actor
      • Tasks
        • Run
    • Apify Dataset
      • Tasks
        • Get
        • GetLastRun
        • Save
  • Arrow Flight SQL
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • AS400
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Atlassian Jira
    • Issues
      • Tasks
        • Create
        • CreateComment
        • UpdateFields
  • AWS
    • S3
      • Tasks
        • Copy
        • CreateBucket
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • Upload
      • Triggers
        • Trigger
    • SNS
      • Tasks
        • Publish
    • CloudFormation
      • Tasks
        • Create
        • Delete
    • Authentication
      • Tasks
        • EksToken
    • Eventbridge
      • Tasks
        • PutEvents
    • SQS
      • Tasks
        • Consume
        • Publish
      • Triggers
        • RealtimeTrigger
        • Trigger
    • ECR
      • Tasks
        • GetAuthToken
    • Glue
      • Tasks
        • GetJobRun
        • StartJobRun
        • StopJobRun
    • EMR
      • Tasks
        • CreateClusterAndSubmitSteps
        • DeleteCluster
        • SubmitSteps
    • Athena
      • Tasks
        • Query
    • Dynamodb
      • Tasks
        • DeleteItem
        • GetItem
        • PutItem
        • Query
        • Scan
    • Kinesis
      • Tasks
        • PutRecords
    • Lambda
      • Tasks
        • Invoke
    • CLI
      • Tasks
        • AwsCLI
    • CloudWatch
      • Tasks
        • Push
        • Query
      • Triggers
        • Trigger
  • AWS (EE)
    • Amazon CloudWatch
      • Log Exporters
        • LogExporter
    • Amazon S3
      • Log Exporters
        • LogExporter
    • AWS Batch Task Runner
      • Task Runners
        • Batch
  • Azure
    • CLI
      • Tasks
        • AzCLI
    • Function
      • Tasks
        • HttpFunction
    • Table
      • Tasks
        • Bulk
        • Delete
        • Get
        • List
    • Authentication
      • Tasks
        • OauthAccessToken
    • Eventhubs
      • Tasks
        • Consume
        • Produce
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Datafactory
      • Tasks
        • CreateRun
    • ADLS
      • Tasks
        • Delete
        • DeleteFiles
        • List
        • Read
        • Reads
        • SharedAccess
        • Upload
      • Triggers
        • Trigger
    • Job
      • Tasks
        • Create
    • Pool
      • Tasks
        • Resize
    • Blob
      • Tasks
        • Copy
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • SharedAccess
        • Upload
      • Triggers
        • Trigger
  • Azure (EE)
    • Runner
      • Task Runners
        • Batch
    • Monitor
      • Log Exporters
        • LogExporter
    • Storage
      • Log Exporters
        • LogExporter
  • Bun
    • Tasks
      • Commands
      • Script
  • ClickHouse
    • Tasks
      • BulkInsert
      • ClickHouseLocalCLI
      • Queries
      • Query
    • Triggers
      • Trigger
  • CloudQuery
    • Tasks
      • CloudQueryCLI
      • Sync
  • Compression
    • Tasks
      • ArchiveCompress
      • ArchiveDecompress
      • FileCompress
      • FileDecompress
  • Confluence
    • Confluence Pages
      • Tasks
        • Create
        • List
        • Update
  • Couchbase
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Cryptography
    • OpenPGP
      • Tasks
        • Decrypt
        • Encrypt
  • Dagster
    • Tasks
      • TriggerRun
  • Databricks
    • SQL
      • Tasks
        • Query
    • DBFS
      • Tasks
        • Download
        • Upload
    • Job
      • Tasks
        • CreateJob
        • SubmitRun
    • CLI
      • Tasks
        • DatabricksCLI
        • DatabricksSQLCLI
    • Cluster
      • Tasks
        • CreateCluster
        • DeleteCluster
  • Datadog (EE)
    • Log Exporters
      • LogExporter
  • Dataform
    • Dataform CLI
      • Tasks
        • DataformCLI
  • Datagen
    • Generators
      • Additional Plugins
        • JsonObjectGenerator
        • RandomBytesGenerator
        • StringValueGenerator
    • Core
      • Tasks
        • Generate
      • Triggers
        • RealtimeTrigger
        • Trigger
  • DataHub
    • Tasks
      • Ingestion
  • DB2
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • DBT
    • Dbt CLI
      • Tasks
        • DbtCLI
    • Dbt Cloud
      • Tasks
        • CheckStatus
        • TriggerRun
  • Debezium DB2
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium Microsoft SQL Server
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium MongoDB
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium MySQL
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium Oracle
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Debezium PostgreSQL
    • Tasks
      • Capture
    • Triggers
      • RealtimeTrigger
      • Trigger
  • Deepseek
    • Tasks
      • ChatCompletion
  • Deno
    • Tasks
      • Commands
      • Script
  • Dlt
    • Tasks
      • CLI
      • Run
  • Docker
    • Tasks
      • Build
      • Prune
      • Pull
      • Rm
      • Run
      • Stop
  • DocumentDB
    • Tasks
      • Delete
      • Insert
      • Read
      • Update
  • Dremio
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Dropbox
    • Dropbox Files
      • Tasks
        • Copy
        • CreateFolder
        • Delete
        • Download
        • GetMetadata
        • List
        • Move
        • Search
        • Upload
  • DuckDB
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Elasticsearch
    • Tasks
      • Bulk
      • Esql
      • Get
      • Load
      • Put
      • Request
      • Scroll
      • Search
  • Elasticsearch (EE)
    • Log Exporters
      • LogExporter
  • File system
    • FTPS (File Transfer Protocol Secure)
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • FTP (File Transfer Protocol)
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • SMB (Server Message Block)
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • SSH (Secure Shell)
      • Tasks
        • Command
    • SFTP (SSH File Transfer Protocol)
      • Tasks
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Triggers
        • Trigger
    • Local
      • Tasks
        • Copy
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
      • Triggers
        • Trigger
    • NFS
      • Tasks
        • CheckMount
        • Copy
        • Delete
        • List
        • Move
      • Triggers
        • Trigger
    • TCP
      • Tasks
        • Send
      • Triggers
        • RealtimeTrigger
    • UDP
      • Tasks
        • Send
      • Triggers
        • RealtimeTrigger
  • Fivetran
    • Connectors
      • Tasks
        • Sync
  • Gemini
    • Tasks
      • ChatCompletion
      • MultimodalCompletion
      • StructuredOutputCompletion
      • TextCompletion
      • VideoGeneration
  • Git
    • Tasks
      • Clone
      • NamespaceSync
      • PushDashboards
      • PushExecutionFiles
      • PushFlows
      • PushNamespaceFiles
      • SyncDashboards
      • SyncFlow
      • SyncFlows
      • SyncNamespaceFiles
      • TenantSync
  • Git (EE)
    • Git
      • Tasks
        • NamespaceSync
        • TenantSync
  • GitHub
    • Tasks
      • RunWorkflow
      • Search
      • Search
      • Comment
      • Create
      • Search
      • Create
      • Search
      • Search
      • Search
      • Search
  • GitLab
    • Tasks
      • MergeRequest
      • Create
      • Search
  • Go
    • Tasks
      • Commands
      • Script
  • Google Cloud
    • CLI
      • Tasks
        • GCloudCLI
    • DataForm
      • Tasks
        • InvokeWorkflow
    • Dataproc Clusters
      • Tasks
        • Create
        • Delete
    • BigQuery
      • Tasks
        • Copy
        • CopyPartitions
        • CreateDataset
        • CreateTable
        • DeleteDataset
        • DeletePartitions
        • DeleteTable
        • ExtractToGcs
        • Load
        • LoadFromGcs
        • Query
        • StorageWrite
        • TableMetadata
        • UpdateDataset
        • UpdateTable
      • Triggers
        • Trigger
    • Kubernetes Engine (GKE)
      • Tasks
        • ClusterMetadata
    • Vertex AI
      • Tasks
        • ChatCompletion
        • CustomJob
        • MultimodalCompletion
        • TextCompletion
    • Dataproc Batches
      • Tasks
        • PySparkSubmit
        • RSparkSubmit
        • SparkSqlSubmit
        • SparkSubmit
    • Google Cloud Function
      • Tasks
        • HttpFunction
    • Firestore
      • Tasks
        • Delete
        • Get
        • Query
        • Set
    • Pub/Sub
      • Tasks
        • Consume
        • Publish
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Cloud Monitoring (Observability)
      • Tasks
        • Push
        • Query
      • Triggers
        • Trigger
    • Cloud Storage (GCS)
      • Tasks
        • Compose
        • Copy
        • CreateBucket
        • CreateBucketIamPolicy
        • Delete
        • DeleteBucket
        • DeleteList
        • Download
        • Downloads
        • List
        • UpdateBucket
        • Upload
      • Triggers
        • Trigger
    • Authentication
      • Tasks
        • OauthAccessToken
  • Google Cloud (EE)
    • Cloud Operations Suite
      • Log Exporters
        • LogExporter
    • Cloud Storage (GCS)
      • Log Exporters
        • LogExporter
    • Google Cloud Task Runner
      • Task Runners
        • Batch
        • CloudRun
  • Google Workspace
    • Drive
      • Tasks
        • Create
        • Delete
        • Download
        • Export
        • List
        • Upload
      • Triggers
        • FileCreatedTrigger
    • Sheets
      • Tasks
        • CreateSpreadsheet
        • DeleteSpreadsheet
        • Load
        • Read
        • ReadRange
      • Triggers
        • SheetModifiedTrigger
    • Calendar
      • Tasks
        • DeleteEvent
        • GetEvent
        • InsertEvent
        • ListEvents
        • UpdateEvent
      • Triggers
        • EventCreatedTrigger
    • Mail
      • Tasks
        • Get
        • List
        • Send
      • Triggers
        • MailReceivedTrigger
  • GraalVM
    • Ruby
      • Tasks
        • Eval
        • FileTransform
    • JS
      • Tasks
        • Eval
        • FileTransform
    • Python
      • Tasks
        • Eval
        • FileTransform
  • GraphQL
    • Tasks
      • Request
  • Grok
    • Grok
      • Tasks
        • TransformItems
        • TransformValue
  • Groovy
    • Tasks
      • Commands
      • Script
  • Hightouch
    • Tasks
      • Sync
  • HubSpot
    • Tasks
      • Create
      • Delete
      • Get
      • Search
      • Update
      • Create
      • Delete
      • Get
      • Search
      • Update
      • Create
      • Delete
      • Get
      • Search
      • Update
      • Create
  • Huggingface
    • Tasks
      • Inference
  • InfluxDB
    • Tasks
      • FluxQuery
      • InfluxQLQuery
      • Load
      • Write
    • Triggers
      • FluxTrigger
  • JBang
    • Tasks
      • Commands
      • Script
  • Jenkins
    • Tasks
      • JobBuild
      • JobInfo
  • JMS
    • Tasks
      • Consume
      • Produce
    • Triggers
      • RealtimeTrigger
  • JSONata
    • JSONata
      • Tasks
        • TransformItems
        • TransformValue
  • Julia
    • Tasks
      • Commands
      • Script
  • Kestra Plugin
    • Kestra Namespaces
      • Tasks
        • List
        • NamespacesWithFlows
    • Kestra Tests
      • Tasks
        • RunTest
        • RunTests
    • Kestra Executions
      • Tasks
        • Delete
        • Kill
        • Query
    • Kestra Flows
      • Tasks
        • Export
        • ExportById
        • List
  • Kubernetes
    • Kubectl
      • Tasks
        • Apply
        • Delete
        • Get
        • Patch
        • Restart
    • Core
      • Tasks
        • PodCreate
  • Kubernetes (EE)
    • Task Runners
      • Kubernetes
  • LDAP
    • Tasks
      • Add
      • Delete
      • IonToLdif
      • LdifToIon
      • Modify
      • Search
  • Linear
    • Tasks
      • Create
  • LinkedIn
    • Tasks
      • AbstractLinkedinTask
      • GetPostAnalytics
      • OAuth2
    • Triggers
      • CommentTrigger
  • Liquibase
    • Tasks
      • CLI
      • Diff
  • Lua
    • Tasks
      • Commands
      • Script
  • Malloy CLI
    • Tasks
      • CLI
  • MariaDB
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Meilisearch
    • Tasks
      • DocumentAdd
      • DocumentGet
      • FacetSearch
      • Search
  • Meta
    • Facebook
      • Tasks
        • Create
        • Delete
        • GetInsights
        • List
        • Schedule
    • Meta plugin for Instagram Business account
      • Tasks
        • CreateCarousel
        • CreateImage
        • CreateVideo
        • GetInsights
        • List
  • Microsoft 365
    • SharePoint
      • Tasks
        • Create
        • Delete
        • Download
        • Export
        • List
        • Upload
    • Outlook
      • Tasks
        • Get
        • List
        • Send
      • Triggers
        • MailReceivedTrigger
    • OneShare
      • Tasks
        • Create
        • Delete
        • Download
        • Export
        • List
        • Upload
      • Triggers
        • Trigger
  • Microsoft SQL Server
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • MinIO
    • Tasks
      • Copy
      • CreateBucket
      • Delete
      • DeleteList
      • Download
      • Downloads
      • List
      • Upload
    • Triggers
      • Trigger
  • Mistral
    • Tasks
      • ChatCompletion
  • Modal
    • Modal CLI
      • Tasks
        • ModalCLI
  • MongoDB
    • Tasks
      • Aggregate
      • Bulk
      • Delete
      • Find
      • InsertOne
      • Load
      • Update
    • Triggers
      • Trigger
  • MQTT
    • Tasks
      • Publish
      • Subscribe
    • Triggers
      • RealtimeTrigger
      • Trigger
  • MySQL
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • N8n
    • N8n Webhooks
      • Tasks
        • TriggerWorkflow
  • NATS
    • Core
      • Tasks
        • Consume
        • Produce
        • Request
      • Triggers
        • RealtimeTrigger
        • Trigger
    • Kv
      • Tasks
        • CreateBucket
        • Delete
        • Get
        • Put
  • Neo4j
    • Tasks
      • Batch
      • Query
  • New Relic (EE)
    • Newrelic
      • Log Exporters
        • LogExporter
  • Node
    • Tasks
      • Commands
      • Script
  • Notifications
    • Teams
      • Tasks
        • TeamsExecution
        • TeamsIncomingWebhook
    • Mail
      • Tasks
        • MailExecution
        • MailSend
      • Triggers
        • MailReceivedTrigger
        • RealTimeTrigger
    • Sentry
      • Tasks
        • SentryAlert
        • SentryExecution
    • Messenger
      • Tasks
        • MessengerExecution
    • Telegram
      • Tasks
        • TelegramExecution
        • TelegramSend
    • Squadcast
      • Tasks
        • SquadcastExecution
        • SquadcastIncomingWebhook
    • Twilio
      • Tasks
        • TwilioAlert
        • TwilioExecution
    • Line
      • Tasks
        • LineExecution
    • Google
      • Tasks
        • GoogleChatExecution
        • GoogleChatIncomingWebhook
    • Sendgrid
      • Tasks
        • SendGridMailExecution
        • SendGridMailSend
    • Pagerduty
      • Tasks
        • PagerDutyAlert
        • PagerDutyExecution
    • Slack
      • Tasks
        • SlackExecution
        • SlackIncomingWebhook
    • X
      • Tasks
        • XExecution
    • Opsgenie
      • Tasks
        • OpsgenieAlert
        • OpsgenieExecution
    • Whatsapp
      • Tasks
        • WhatsAppExecution
        • WhatsAppIncomingWebhook
    • Discord
      • Tasks
        • DiscordExecution
        • DiscordIncomingWebhook
    • Zenduty
      • Tasks
        • ZendutyAlert
        • ZendutyExecution
    • Zulip
      • Tasks
        • ZulipExecution
        • ZulipIncomingWebhook
  • Notion
    • Tasks
      • Archive
      • Create
      • Read
      • Update
  • Odoo
    • Tasks
      • Query
  • Ollama
    • CLI
      • Tasks
        • OllamaCLI
  • OpenAI
    • Tasks
      • ChatCompletion
      • CreateImage
      • Responses
      • UploadFile
  • OpenSearch
    • Tasks
      • Bulk
      • Get
      • Load
      • Put
      • Request
      • Scroll
      • Search
  • Opensearch (EE)
    • Log Exporters
      • LogExporter
  • Opentelemetry (EE)
    • Log Exporters
      • LogExporter
  • Oracle
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • Perl
    • Tasks
      • Commands
      • Script
  • Perplexity
    • Tasks
      • ChatCompletion
  • PHP
    • Tasks
      • Commands
      • Script
  • PostgreSQL
    • Tasks
      • Batch
      • CopyIn
      • CopyOut
      • Queries
      • Query
    • Triggers
      • Trigger
  • Power BI
    • Tasks
      • RefreshGroupDataset
  • PowerShell
    • Tasks
      • Commands
      • Script
  • Prefect
    • Tasks
      • CreateFlowRun
  • Prometheus
    • Tasks
      • Push
      • Query
    • Triggers
      • Trigger
  • Python
    • Tasks
      • Commands
      • Script
  • Redis
    • String
      • Tasks
        • Delete
        • Get
        • Increment
        • Set
        • Ttl
    • List
      • Tasks
        • ListPop
        • ListPush
      • Triggers
        • RealtimeTrigger
        • Trigger
    • JSON
      • Tasks
        • Delete
        • Get
        • Increment
        • Set
    • PubSub
      • Tasks
        • Publish
  • Resend
    • Domain
      • Tasks
        • Create
    • Email
      • Tasks
        • Send
  • RScript
    • Tasks
      • Commands
      • Script
  • Ruby
    • Tasks
      • Commands
      • Script
  • Salesforce (EE)
    • Tasks
      • Create
      • Delete
      • SoqlQuery
      • Update
    • Triggers
      • Trigger
  • Serialization
    • XML
      • Tasks
        • IonToXml
        • XmlToIon
    • CSV
      • Tasks
        • CsvToIon
        • IonToCsv
    • Excel
      • Tasks
        • ExcelToIon
        • IonToExcel
    • Avro
      • Tasks
        • AvroToIon
        • InferAvroSchemaFromIon
        • IonToAvro
    • Markdown
      • Tasks
        • MarkdownToHtml
        • MarkdownToText
    • Parquet
      • Tasks
        • IonToParquet
        • ParquetToIon
    • JSON
      • Tasks
        • IonToJson
        • JsonToIon
        • JsonToJsonl
        • JsonToToon
        • ToonToJson
    • Protobuf
      • Tasks
        • ProtobufToIon
  • ServiceNow
    • Tasks
      • Delete
      • Get
      • Post
      • Update
  • Shell
    • Tasks
      • Commands
      • Script
  • Shopify
    • Shopify Order
      • Tasks
        • Delete
        • List
    • Shopify Order
      • Tasks
        • List
        • Update
    • Shopify Customer
      • Tasks
        • Create
        • Delete
        • Get
        • List
  • Sifflet
    • Tasks
      • RunRule
  • SNMP
    • Tasks
      • SendInform
      • SendTrap
  • Snowflake
    • Tasks
      • Download
      • Queries
      • Query
      • SnowflakeCLI
      • Upload
    • Triggers
      • Trigger
  • Soda
    • Tasks
      • Scan
  • Solace
    • Tasks
      • Consume
      • Produce
    • Triggers
      • Trigger
  • Splunk (EE)
    • Log Exporters
      • LogExporter
  • SQLite
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • SQLMesh
    • SQLMesh CLI
      • Tasks
        • SQLMeshCLI
  • Stripe
    • Stripe Customer
      • Tasks
        • Create
        • Delete
        • Get
        • List
        • Update
    • Stripe Webhook
      • Tasks
        • HandleEvent
    • Stripe Balance
      • Tasks
        • Retrieve
    • Stripe Payment
      • Tasks
        • AttachMethod
        • ConfirmIntent
        • CreateIntent
        • CreateMethod
        • DetachMethod
        • ListIntents
        • ListMethods
        • Refund
  • Supabase
    • Tasks
      • Delete
      • Insert
      • Query
      • Select
      • Update
  • SurrealDB
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Sybase
    • Tasks
      • Queries
      • Query
    • Triggers
      • Trigger
  • Terraform
    • Tasks
      • TerraformCLI
  • Todoist
    • Tasks
      • CompleteTask
      • CreateTask
      • DeleteTask
      • GetTask
      • ListTasks
      • UpdateTask
  • Trino
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Trivy
    • Trivy
      • Tasks
        • TrivyCLI
  • Typesense
    • Tasks
      • BulkIndex
      • DocumentGet
      • DocumentIndex
      • FacetSearch
      • Search
  • Vertica
    • Tasks
      • Batch
      • Queries
      • Query
    • Triggers
      • Trigger
  • VMware (EE)
    • VMware vCenter
      • Tasks
        • CloneTemplate
        • CloneVm
        • ConvertTemplateToVm
        • ConvertVmToTemplate
        • CreateVm
        • CreateVmSnapshot
        • DeleteVm
        • DeleteVmSnapshot
        • ListVmSnapshots
        • ListVms
        • RebootVm
        • ResetVm
        • RestoreVmFromSnapshot
        • StartVm
        • StopVm
        • SuspendVm
        • UpdateVm
      • Triggers
        • Trigger
    • VMware ESXi
      • Tasks
        • CreateVm
        • CreateVmSnapshot
        • DeleteVm
        • DeleteVmSnapshot
        • ListVmSnapshots
        • ListVms
        • RebootVm
        • ResetVm
        • RestoreVmFromSnapshot
        • StartVm
        • StopVm
        • SuspendVm
        • UpdateVm
      • Triggers
        • Trigger
  • Weaviate
    • Tasks
      • BatchCreate
      • Delete
      • Query
      • SchemaCreate
  • YouTube
    • Tasks
      • AbstractYoutubeTask
      • OAuth2
      • VideoStats
    • Triggers
      • CommentTrigger
      • VideoTrigger
  • Zendesk
    • Tasks
      • Create
Plugins

Serialization​Serialization

Table of Contents
  • XML
  • CSV
  • Excel
  • Avro
  • Markdown
  • Parquet
  • JSON
  • Protobuf
Contribute
  • Join us on Slack
  • YouTube
  • GitHub
  • Twitter
  • BlueSky
  • LinkedIn

Serialize and deserialize data formats in Kestra workflows.

XML iconXML CSV iconCSV Excel iconExcel Avro iconAvro Markdown iconMarkdown Parquet iconParquet JSON iconJSON Protobuf iconProtobuf
Kestra's logo

Open Source Declarative Data Orchestration

Get Kestra updates

Stay up to date with the latest features and changes to Kestra

Product
  • Platform Overview
  • Open Source
  • Enterprise Edition
  • Kestra Cloud
  • Pricing
Solutions
  • Use Cases
  • Declarative Orchestration
  • Automation Platform
  • API First
  • Code in Any Language
  • Terraform Provider
  • Airflow vs Kestra
  • Prefect vs Kestra
  • Dagster vs Kestra
  • AWS Step Functions vs Kestra
Community
  • Community Overview
  • Blog
  • Write for Us
  • Slack
  • GitHub
Docs
  • Documentation
  • Plugins
  • Blueprints
  • Getting Started
  • Administrator Guide
  • FAQ
Company
  • About Us
  • Careers Hiring!
  • Contact Us
  • Customer Stories
  • Partners Ecosystem
SOC 2GDPR

© 2025 Kestra Technologies. Developed with on 🌎.

Privacy Policy / Cookie Policy

Slack