Skip to content

File Store

File Store (file-store)

Write to a local file system object store bucket.

Contents

Fields

FieldTypeRequiredDescription
retryRetryRetry on failure.
batchBatchWrite events as batches.
pathpath (string)Select filesystem path as root of store.
object-namefile_store_output:object-nameFile Name (may contain slashes).
modeModeSpecify whether we’re putting or deleting.
input-fieldevent-field (string)Use the specified field as the content for the file line.
preprocessorsPreprocessorsPreprocessors (process data before making it available for upload) these processors will be run in the order they are specified.
track-schemaboolean (bool)Check the schema of the written data and update __SCHEMA_NUMBER (written data must be JSON).

Object properties

Object Properties
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.

Retry Fields

FieldTypeRequiredDescription
countintegerThe number of retry attempts. If unspecified, retries will continue indefinitely.
pausestringHow long to pause before re-trying.

Batch Fields

FieldTypeRequiredDescription
fixed-sizeintegermaximum number of events in an output batch.
modesymbolIf ‘document’ send on end of document generated by input. If ‘fixed’, use fixed_size.
timeoutstringinterval after which the batch is sent, to keep throughput going (default 100ms).
headerstringput a header line before the batch.
footerstringput a header line after the last line of the batch.
use-document-markerboolEnrich the job metadata with a document marker (for document handling in batch mode).
wrap-as-jsonboolFormat the output batch as a JSON array.

Mode Options

ValueNameDescription
putputPut Objects
deletedeleteDelete Objects

Preprocessors Options

ValueNameDescription
gzipgzipGzip the output data
parquetparquetExtract the received data as JSON rows from a parquet file
base64base64Decode base64 as binary