Serialization

XML

Tasks that convert between XML and Ion.

CSV

Tasks that convert between CSV and Ion.

Excel

Tasks that convert between Excel and Ion.

YAML

Tasks that convert between YAML and Ion/JSON.

Avro

Tasks that convert to/from Apache Avro and validate schemas.

Markdown

Tasks that convert Markdown to text or HTML.

Parquet

Tasks that convert between Parquet and Ion.

JSON

Tasks that convert JSON and JSONL to/from Ion.

Protobuf

Tasks that convert Protocol Buffers messages to/from Ion.

Extract data, transform it, and load it in parallel to S3 and Postgres — in less than 7 seconds!

Export Kestra audit logs as a CSV file and send out via Email.

Stream kestra audit logs from a Kafka topic to BigQuery for analytics and troubleshooting

Apache Beam

Tasks that run pipelines against SDKs and dedicated runners including Apache Flink

TransformationBatchIngestion

Cryptography

Tasks that secure files in Kestra pipelines using OpenPGP encryption, decryption, and signature validation.

Transformation

LDAP

Tasks that query and modify LDAP directories.

DatabaseTransformation