Kestra, Open source declarative data orchestrationKestra, Open source declarative data orchestration
  • Product

    • Open Source
      Discover all the features of Kestra

    • Enterprise Edition
      Security and High Availability for enterprise

    • Declarative Orchestration
      Simplified data workflow creation and execution

  • Solutions

    • Use cases
      Uncover a wide range of use cases

    • CI/CD for Kestra Workflows
      Treat your workflow as code and embrace CI/CD practices

    • Modern Data Stack Integration
      Integrate leading data tools with Kestra

    • Change Data Capture
      Leverage Kestra's Change Data Capture capabilities

  • Docs
  • Plugins
  • Blog
  • Resources

    • Community Overview
      Ask any questions and share your feedback

    • Partners
      Elevate your Kestra use through our partner ecosystem

    • FAQ
      FAQ about the product and the company

    • About us
      Discover our story and meet our team

    • Careers
      Join a remote-first company

    • Contact us
      Get in touch with us

  • Star us Book a demo Get Started Search
  • Core
    • Conditions
      • DateTimeBetweenCondition
      • DayWeekCondition
      • DayWeekInMonthCondition
      • ExecutionFlowCondition
      • ExecutionNamespaceCondition
      • ExecutionStatusCondition
      • FlowCondition
      • FlowNamespaceCondition
      • HasRetryAttemptCondition
      • MultipleCondition
      • NotCondition
      • OrCondition
      • TimeBetweenCondition
      • VariableCondition
      • WeekendCondition
    • Tasks
      • Debugs
        • Echo
        • Return
      • Executions
        • Counts
        • Fail
      • Flows
        • AllowFailure
        • Dag
        • EachParallel
        • EachSequential
        • Flow
        • If
        • Parallel
        • Pause
        • Sequential
        • Switch
        • Template
        • Worker
        • WorkingDirectory
      • Log
        • Fetch
        • Log
      • States
        • Delete
        • Get
        • Set
      • Storages
        • Concat
        • Delete
        • LocalFiles
        • Purge
        • PurgeExecution
        • Size
        • Split
    • Triggers
      • Flow
      • Schedule
      • Webhook
  • Actian Vector
    • Tasks
      • Batch
      • Query
    • Triggers
      • Trigger
  • Airbyte
    • Tasks
      • CloudJobs
        • Reset
        • Sync
      • Connections
        • Sync
  • Amazon Redshift
    • Tasks
      • Query
    • Triggers
      • Trigger
  • AMQP
    • Tasks
      • Consume
      • CreateQueue
      • DeclareExchange
      • Publish
      • QueueBind
    • Triggers
      • Trigger
  • Apache Cassandra
    • Tasks
      • Query
      • Query
  • Apache Kafka
    • Tasks
      • Consume
      • Produce
    • Triggers
      • Trigger
  • Apache Pinot
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Apache Pulsar
    • Tasks
      • Consume
      • Produce
      • Reader
    • Triggers
      • Trigger
  • Apache Spark
    • Tasks
      • JarSubmit
      • PythonSubmit
      • RSubmit
      • SparkCLI
  • Apache Tika
    • Tasks
      • Parse
  • AWS
    • Tasks
      • Athena
        • Query
      • Cli
        • AwsCLI
      • Dynamodb
        • DeleteItem
        • GetItem
        • PutItem
        • Query
        • Scan
      • Lambda
        • Invoke
      • S3
        • Copy
        • CreateBucket
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • Upload
      • Sns
        • Publish
      • Sqs
        • Consume
        • Publish
    • Triggers
      • S3
        • Trigger
      • Sqs
        • Trigger
  • Azure
    • Tasks
      • BatchJob
        • Create
      • BatchPool
        • Resize
      • Cli
        • AzCLI
      • StorageBlob
        • Copy
        • Delete
        • DeleteList
        • Download
        • Downloads
        • List
        • SharedAccess
        • Upload
      • StorageTable
        • Bulk
        • Delete
        • Get
        • List
    • Triggers
      • StorageBlob
        • Trigger
  • ClickHouse
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Compression
    • Tasks
      • ArchiveCompress
      • ArchiveDecompress
      • FileCompress
      • FileDecompress
  • Couchbase
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Cryptography
    • Tasks
      • Openpgp
        • Decrypt
        • Encrypt
  • Databricks
    • Tasks
      • Cluster
        • CreateCluster
        • DeleteCluster
      • Dbfs
        • Download
        • Upload
      • Job
        • CreateJob
        • SubmitRun
      • Sql
        • Query
  • Dbt
    • Tasks
      • Cli
        • Build
        • Compile
        • DbtCLI
        • Deps
        • Freshness
        • List
        • Run
        • Seed
        • Setup
        • Snapshot
        • Test
      • Cloud
        • TriggerRun
  • Debezium Microsoft SQL Server
    • Tasks
      • Capture
    • Triggers
      • Trigger
  • Debezium MySQL
    • Tasks
      • Capture
    • Triggers
      • Trigger
  • Debezium PostgreSQL
    • Tasks
      • Capture
    • Triggers
      • Trigger
  • DuckDB
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Elasticsearch
    • Tasks
      • Bulk
      • Get
      • Load
      • Put
      • Request
      • Scroll
      • Search
  • File system
    • Tasks
      • Ftp
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Ftps
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Http
        • Download
        • Request
      • Sftp
        • Delete
        • Download
        • Downloads
        • List
        • Move
        • Upload
        • Uploads
      • Ssh
        • Command
    • Triggers
      • Ftp
        • Trigger
      • Ftps
        • Trigger
      • Sftp
        • Trigger
  • Fivetran
    • Tasks
      • Connectors
        • Sync
  • Git
    • Tasks
      • Clone
  • Google Cloud
    • Tasks
      • Auth
        • OauthAccessToken
      • Bigquery
        • Copy
        • CopyPartitions
        • CreateDataset
        • CreateTable
        • DeleteDataset
        • DeletePartitions
        • DeleteTable
        • ExtractToGcs
        • Load
        • LoadFromGcs
        • Query
        • StorageWrite
        • TableMetadata
        • UpdateDataset
        • UpdateTable
      • Cli
        • GCloudCLI
      • DataprocBatches
        • PySparkSubmit
        • RSparkSubmit
        • SparkSqlSubmit
        • SparkSubmit
      • Firestore
        • Delete
        • Get
        • Query
        • Set
      • Gcs
        • Compose
        • Copy
        • CreateBucket
        • CreateBucketIamPolicy
        • Delete
        • DeleteBucket
        • DeleteList
        • Download
        • Downloads
        • List
        • UpdateBucket
        • Upload
      • Gke
        • ClusterMetadata
      • Pubsub
        • Consume
        • Publish
      • Vertexai
        • ChatCompletion
        • CustomJob
        • TextCompletion
    • Triggers
      • Bigquery
        • Trigger
      • Gcs
        • Trigger
      • Pubsub
        • Trigger
  • Google Workspace
    • Tasks
      • Drive
        • Create
        • Delete
        • Download
        • Export
        • List
        • Upload
      • Sheets
        • Read
        • ReadRange
  • Groovy
    • Tasks
      • Eval
      • FileTransform
  • Hightouch
    • Tasks
      • Sync
  • Julia
    • Tasks
      • Commands
      • Script
  • Jython
    • Tasks
      • Eval
      • FileTransform
  • Kubernetes
    • Tasks
      • PodCreate
  • Malloy CLI
    • Tasks
      • CLI
  • Microsoft SQL Server
    • Tasks
      • Batch
      • Query
    • Triggers
      • Trigger
  • MongoDB
    • Tasks
      • Bulk
      • Delete
      • Find
      • InsertOne
      • Load
      • Update
  • MQTT
    • Tasks
      • Publish
      • Subscribe
    • Triggers
      • Trigger
  • MySQL
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Nashorn
    • Tasks
      • Eval
      • FileTransform
  • NATS
    • Tasks
      • Consume
      • Produce
    • Triggers
      • Trigger
  • Neo4j
    • Tasks
      • Batch
      • Query
  • Node
    • Tasks
      • Node
      • Commands
      • Script
  • Notifications
    • Tasks
      • Mail
        • MailExecution
        • MailSend
      • Slack
        • SlackExecution
        • SlackIncomingWebhook
      • Teams
        • TeamsExecution
        • TeamsIncomingWebhook
      • Telegram
        • TelegramExecution
        • TelegramSend
  • OpenAI
    • Tasks
      • ChatCompletion
      • CreateImage
  • Oracle
    • Tasks
      • Batch
      • Query
    • Triggers
      • Trigger
  • PostgreSQL
    • Tasks
      • Batch
      • CopyIn
      • CopyOut
      • Query
    • Triggers
      • Trigger
  • Power BI
    • Tasks
      • RefreshGroupDataset
  • PowerShell
    • Tasks
      • Commands
      • Script
  • Python
    • Tasks
      • Python
      • Commands
      • Script
  • Redis
    • Tasks
      • Delete
      • Get
      • ListPop
      • ListPush
      • Publish
      • Set
    • Triggers
      • TriggerList
  • Rockset
    • Tasks
      • Query
    • Triggers
      • Trigger
  • RScript
    • Tasks
      • Commands
      • Script
  • Serialization
    • Tasks
      • Avro
        • AvroConverter
        • AvroReader
        • AvroWriter
      • Csv
        • CsvReader
        • CsvWriter
      • Json
        • JsonReader
        • JsonWriter
      • Parquet
        • ParquetReader
        • ParquetWriter
      • Xml
        • XmlReader
        • XmlWriter
  • ServiceNow
    • Tasks
      • Post
  • Shell
    • Tasks
      • Bash
      • Commands
      • Script
  • Singer
    • Tasks
      • Taps
        • BigQuery
        • BingAds
        • ChargeBee
        • ExchangeRateHost
        • FacebookAds
        • Fastly
        • GitHub
        • Gitlab
        • GoogleAdwords
        • GoogleAnalytics
        • GoogleSearchConsole
        • Marketo
        • Netsuite
        • PipelinewiseMongoDb
        • PipelinewiseMysql
        • PipelinewiseOracle
        • PipelinewisePostgres
        • PipelinewiseSqlServer
        • Quickbooks
        • Recharge
        • SageIntacct
        • Salesforce
        • Shopify
        • Slack
        • Stripe
        • Zendesk
        • Zoom
      • Targets
        • AdswerveBigQuery
        • Csv
        • DatamillCoPostgres
        • Json
        • MeltanoSnowflake
        • Oracle
        • PipelinewisePostgres
        • PipelinewiseRedshift
        • PipelinewiseSnowflake
        • SqlServer
  • Snowflake
    • Tasks
      • Download
      • Query
      • Upload
    • Triggers
      • Trigger
  • Soda
    • Tasks
      • Scan
  • Template
  • Trino
    • Tasks
      • Query
    • Triggers
      • Trigger
  • Vertica
    • Tasks
      • Batch
      • Query
    • Triggers
      • Trigger
PLUGINSPLUGIN-SCRIPT-NODE

​Node

Table of Contents
  • Tasks
Contribute
  • Join us on Slack
  • GitHub
  • Twitter
  • LinkedIn

Node

Execute Node scripts as part of Kestra data workflows.

Tasks

  • Node
  • Commands
  • Script
TasksFileTransform
Plugin Script NodeTasks
Kestra's logo

Open Source Declarative Data Orchestration

Product
  • Features
  • Connectors
  • Enterprise Edition
Solutions
  • Usages
  • CI/CD for Kestra Workflows
  • Modern Data Stack Integration
  • Change Data Capture
  • Airflow vs Kestra
  • Prefect vs Kestra
  • Dagster vs Kestra
Community
  • Community Overview
  • Blog
  • Slack
  • Github
Docs
  • Documentation
  • Plugins documentation
  • Terraform provider
  • Administrator guide
  • FAQ
Company
  • About us
  • Careers
  • Contact us

© 2023 Kestra Technologies. Developed with in the 🌎.

Privacy Policy / Cookie Policy

Slack