Read from a local file system object store bucket.
| Field | Type | Required | Description |
|---|
trigger | trigger | | How often to run the command. |
path | path (string) | ✅ | Select filesystem path as root of store. |
object-names | string | ✅ | Names for objects. If we are listing these are prefixes. |
mode | Mode | | List-and-download, List or just download. |
ignore-linebreaks | boolean (bool) | | Treat object as one event. |
timestamp-mode | Timestamp Mode | | Derive a timestamp for this blob for filtering purposes based on the selected strategy. |
maximum-age | string | | Remove any blobs older than this many seconds from the candidate list. |
fingerprinting | boolean (bool) | | Enable object fingerprinting, which will cause a object to only be downloaded once. |
fingerprinting-db-path | path (string) | | Specify a custom path for the fingerprinting database. |
maximum-fingerprint-age | duration (string) | | Remove any object fingerprints older than this from the tracker. |
preprocessors | Preprocessors | | Preprocessors (process downloaded data before making it available to the job) these processors will be run in the order they are specified. |
include-regex | string | | Include objects matching the specified regular expressions. |
exclude-regex | string | | Exclude objects matching the specified regular expressions. |
retry | Retry | | Timeout and Retry. |
Object Properties
| Field | Type | Required | Description |
|---|
object-name-field | event-field (string) | | The field that a blob name from an operation should be stored in. |
creation-time-field | event-field (string) | | The field that the blob creation time should be stored in. |
last-modified-field | event-field (string) | | The field that the blob last modified time should be stored in. |
content-length-field | event-field (string) | | The field that the blob content length information should be stored in. |
content-type-field | event-field (string) | | The field that the blob content type information should be stored in. |
etag-field | event-field (string) | | The field that the object ETag should be stored in. |
data-field | event-field (string) | | A field that the blob data should be nested in. |
| Field | Type | Required | Description |
|---|
count | integer | | How to retry? Either forever or for a limited number of times. |
pause | string | | How long to pause before re-trying. |
| Value | Name | Description |
|---|
list-and-download-objects | list-and-download-objects | List Objects and Download |
list-objects | list-objects | List Objects |
download-objects | download-objects | Download Given Objects |
| Value | Name | Description |
|---|
none | none | The default mode, do not filter based on timestamps |
last-modified | last-modified | Filter object on the last-modified timestamp reported by the service |
blob-name-pattern | blob-name-pattern | Filter blobs on the timestamp derived from the object name for example: relevant-name-pattern: =(?P<Y>[\\d]{4,4})-(?P<m>[\\d]{2,2})-(?P<d>[\\d]{2,2})/ |
| Value | Name | Description |
|---|
extension | extension | Preprocess the object or blob based on the extension of the object or blob name (.gz, .parquet) |
gzip | gzip | UnGzip the received data |
parquet | parquet | Extract the received data as JSON rows from a parquet file |
base64 | base64 | Encode the binary data as base64 |
