PLUGINSPLUGIN-FSTRIGGERSFTPIO.KESTRA.PLUGIN.FS.FTP.TRIGGER

Trigger

Table of Contents

Contribute

Trigger

yaml

type: "io.kestra.plugin.fs.ftp.Trigger"

Trigger a flow as soon as new files are detected in a given FTP server's directory.

Examples

Wait for one or more files in a given FTP server's directory and process each of these files sequentially.

yaml

id: ftp_trigger_flow
namespace: dev

tasks:
  - id: for_each_file
    type: io.kestra.core.tasks.flows.EachSequential
    value: "{{ trigger.files | jq('.path') }}"
    tasks:
      - id: return
        type: io.kestra.core.tasks.debugs.Return
        format: "{{ taskrun.value }}"

triggers:
  - id: watch
    type: io.kestra.plugin.fs.ftp.Trigger
    host: localhost
    port: 21
    username: foo
    password: bar
    from: "/in/"
    interval: PT10S
    action: MOVE
    moveDirectory: "/archive/"

Wait for one or more files in a given FTP server's directory and process each of these files sequentially. In this example, we restrict the trigger to only wait for CSV files in the mydir directory.

yaml

id: ftp_wait_for_csv_in_mydir
namespace: dev

tasks:
  - id: each
    type: io.kestra.core.tasks.flows.EachSequential
    value: "{{ trigger.files | jq('.path') }}"
    tasks:
      - id: return
        type: io.kestra.core.tasks.debugs.Return
        format: "{{ taskrun.value }}"

triggers:
  - id: watch
    type: io.kestra.plugin.fs.ftp.Trigger
    host: localhost
    port: "21"
    username: foo
    password: bar
    from: "mydir/"
    regExp: ".*.csv"
    action: MOVE
    moveDirectory: "archive/"
    interval: PTS

Properties

`action`

Type: string
Dynamic: ✔️
Required: ✔️
Possible Values:
- MOVE
- DELETE

The action to do on find files

`from`

Type: string
Dynamic: ✔️
Required: ✔️

The directory to list

`host`

Type: string
Dynamic: ✔️
Required: ✔️

Hostname of the remote server

`conditions`

Type: array
SubType: Condition
Dynamic: ❌
Required: ❌

List of Conditions in order to limit the flow trigger.

`interval`

Type: string
Dynamic: ❌
Required: ❌
Default: 60.000000000
Format: duration

The interval between test of triggers

`moveDirectory`

Type: string
Dynamic: ✔️
Required: ❌

The destination directory in case off MOVE

`passiveMode`

Type: boolean
Dynamic: ❌
Required: ❌
Default: true

Whether to use a passive mode. Passive mode is generally considered more secure as it's less likely to encounter issues with NAT and firewalls. Therefore, this property is by default set to true. To use active mode instead, set the property to false.