Trigger a flow as soon as new files are detected in a given SMB (Samba for eg.) server's directory.
type: "io.kestra.plugin.fs.smb.Trigger"Wait for one or more files in a given SMB server's directory and process each of these files sequentially. Then move them to another share which is used as an archive.
id: smb_trigger_flow
namespace: company.team
tasks:
- id: for_each_file
type: io.kestra.plugin.core.flow.ForEach
values: "{{ trigger.files }}"
tasks:
- id: return
type: io.kestra.plugin.core.debug.Return
format: "{{ taskrun.value | jq('.path') }}"
triggers:
- id: watch
type: io.kestra.plugin.fs.smb.Trigger
host: localhost
port: "445"
username: foo
password: bar
from: "/my_share/in/"
interval: PT10S
action: MOVE
moveDirectory: "/archive_share/"
Wait for one or more files in a given SMB server's directory and process each of these files sequentially. Then move them to another share which is used as an archive.
id: smb_trigger_flow
namespace: company.team
tasks:
- id: for_each_file
type: io.kestra.plugin.core.flow.ForEach
values: "{{ trigger.files }}"
tasks:
- id: return
type: io.kestra.plugin.core.debug.Return
format: "{{ taskrun.value | jq('.path') }}"
- id: delete
type: io.kestra.plugin.fs.smb.Delete
host: localhost
port: "445"
username: foo
password: bar
uri: "/my_share/in/{{ taskrun.value | jq('.path') }}"
triggers:
- id: watch
type: io.kestra.plugin.fs.smb.Trigger
host: localhost
port: "445"
username: foo
password: bar
from: "/my_share/in/"
interval: PT10S
action: NONE
Wait for one or more files in a given SMB server's directory (composed of share name followed by dir path) and process each of these files sequentially.
In this example, we restrict the trigger to only wait for CSV files in the mydir directory.
id: smb_wait_for_csv_in_my_share_my_dir
namespace: company.team
tasks:
- id: each
type: io.kestra.plugin.core.flow.ForEach
values: "{{ trigger.files }}"
tasks:
- id: return
type: io.kestra.plugin.core.debug.Return
format: "{{ taskrun.value | jq('.path') }}"
triggers:
- id: watch
type: io.kestra.plugin.fs.smb.Trigger
host: localhost
port: "445"
username: foo
password: bar
from: "my_share/mydir/"
regExp: ".*.csv"
action: MOVE
moveDirectory: "my_share/archivedir"
interval: PTS
The action to perform on the retrieved files. If using 'NONE' make sure to handle the files inside your flow to avoid infinite triggering.
The directory to list
Hostname of the remote server
The interval between test of triggers
The destination directory in case off MOVE
Password on the remote server
Port of the remote server
A regexp to filter on full path
List of execution states after which a trigger should be stopped (a.k.a. disabled).
Username on the remote server