Skip to content

File Store

File Store (file-store)

Write to a local file system object store.

Object Store File binary json raw

Minimal example

output:
file-store:
object-name:
name: ~
path: ""
JSON
{
"output": {
"file-store": {
"object-name": {
"name": null
},
"path": ""
}
}
}

Contents

Fields

FieldTypeRequiredDescription
path Locationpath (string)Select filesystem path as root of store.
Examples: /path/to/file, c:\users\joe\data\file.txt
object-name LocationObject NameFile name (may contain slashes).
retry ReliabilityRetryRetry on failure.
batch ProcessingBatchWrite events as batches.
mode BehaviorModeSpecify whether we’re putting or deleting.
Allowed values: put, delete
input-field Processingfield (string)Use the specified field as the content for the file line.
Examples: data_field
disable-object-name-guid Object Propertiesboolean (bool)Disable the GUID prefix if you want object name to be treated literally (off for deletes).
guid-prefix Object PropertiesstringGUID Prefix, will be prepended to the GUID, the default value is ”/”.
guid-suffix Object PropertiesstringGUID Suffix, will be appended to the GUID if specified.
preprocessors ProcessingPreprocessors[]Preprocessors (process data before making it available for upload) these processors will be run in the order they are specified.
Allowed values: gzip, parquet, base64
track-schema Reliabilityboolean (bool)Check the schema of the written data and update __SCHEMA_NUMBER (written data must be JSON).

Reliability

Show fields
FieldTypeRequiredDescription
retryRetryRetry on failure.
track-schemaboolean (bool)Check the schema of the written data and update __SCHEMA_NUMBER (written data must be JSON).

Processing

Show fields
FieldTypeRequiredDescription
batchBatchWrite events as batches.
input-fieldfield (string)Use the specified field as the content for the file line.
Examples: data_field
preprocessorsPreprocessors[]Preprocessors (process data before making it available for upload) these processors will be run in the order they are specified.
Allowed values: gzip, parquet, base64

Location

Show fields
FieldTypeRequiredDescription
pathpath (string)Select filesystem path as root of store.
Examples: /path/to/file, c:\users\joe\data\file.txt
object-nameObject NameFile name (may contain slashes).

Behavior

Show fields
FieldTypeRequiredDescription
modeModeSpecify whether we’re putting or deleting.
Allowed values: put, delete

Object Properties

Show fields
FieldTypeRequiredDescription
disable-object-name-guidboolean (bool)Disable the GUID prefix if you want object name to be treated literally (off for deletes).
guid-prefixstringGUID Prefix, will be prepended to the GUID, the default value is ”/”.
guid-suffixstringGUID Suffix, will be appended to the GUID if specified.

Schema

Object Name Options

OptionNameTypeDescription
nameNamestringObject Name.
fieldFieldstringField containing the Object Name.

Retry Fields

FieldTypeRequiredDescription
timeouttime-interval (string)timeout (e.g. 500ms, 2s etc. - default is 30).
Examples: 500ms, 2h
retriesnumber (integer)number of retries.
Examples: 42, 1.2e-10

Batch Fields

FieldTypeRequiredDescription
fixed-sizenumber (integer)maximum number of events in an output batch.
Examples: 42, 1.2e-10
modeModeIf ‘document’ send on end of document generated by input. If ‘fixed’, use fixed_size.
Allowed values: fixed, document
timeouttime-interval (string)interval after which the batch is sent, to keep throughput going (default 100ms).
Examples: 500ms, 2h
headermultiline-text (string)put a header line before the batch.
footermultiline-text (string)put a header line after the last line of the batch.
use-document-markerboolean (bool)Enrich the job metadata with a document marker (for document handling in batch mode).
wrap-as-jsonboolean (bool)Format the output batch as a JSON array.

Batch - Mode Options

ValueDescription
fixedFixed
documentDocument

Mode Options

ValueDescription
putPut Objects
deleteDelete Objects

Preprocessors Options

ValueDescription
gzipGzip the output data
parquetExtract the received data as JSON rows from a parquet file
base64Decode base64 as binary