Skip to main content

@terascope/file-asset-apis / s3/s3-fetcher / S3Fetcher

Class: S3Fetcher

Defined in: s3/s3-fetcher.ts:7

Extends

Extended by

Constructors

Constructor

new S3Fetcher(client, config, logger): S3Fetcher

Defined in: s3/s3-fetcher.ts:11

Parameters

ParameterType
clientS3Client
configOmit<ReaderConfig, "size">
loggerLogger

Returns

S3Fetcher

Overrides

ChunkedFileReader.constructor

Properties

PropertyModifierTypeInherited fromDefined in
bucketreadonlystring-s3/s3-fetcher.ts:9
clientprotectedS3Client-s3/s3-fetcher.ts:8
compressorpublicCompressorChunkedFileReader.compressorbase/chunked-file-reader.ts:74
filePerSliceprotectedbooleanChunkedFileReader.filePerSlicebase/chunked-file-reader.ts:83
loggerpublicLoggerChunkedFileReader.loggerbase/chunked-file-reader.ts:73

Accessors

format

Get Signature

get format(): Format

Defined in: base/chunked-file-reader.ts:127

Returns

Format

Inherited from

ChunkedFileReader.format


lineDelimiter

Get Signature

get lineDelimiter(): string

Defined in: base/chunked-file-reader.ts:123

Returns

string

Inherited from

ChunkedFileReader.lineDelimiter

Methods

csv()

protected csv(incomingData, slice): Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Defined in: base/chunked-file-reader.ts:233

Parameters

ParameterType
incomingDatastring
sliceFileSlice

Returns

Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Inherited from

ChunkedFileReader.csv


fetch()

protected fetch(slice): Promise<string>

Defined in: s3/s3-fetcher.ts:27

low level api that fetches the unprocessed contents of the file, please use the "read" method for correct file and data parsing

Parameters

ParameterType
sliceFileSlice

Returns

Promise<string>

Example

const slice = { offset: 0, length: 1000, path: 'some/file.txt', total: 1000 };
const results = await s3Reader.fetch(slice);
results === 'the unprocessed contents of the file here'

Overrides

ChunkedFileReader.fetch


getMargin()

protected getMargin(slice, delimiter): Promise<string>

Defined in: base/chunked-file-reader.ts:200

Parameters

ParameterType
sliceFileSlice
delimiterstring

Returns

Promise<string>

Inherited from

ChunkedFileReader.getMargin


json()

protected json(incomingData, slice): Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Defined in: base/chunked-file-reader.ts:294

Parameters

ParameterType
incomingDatastring
sliceFileSlice

Returns

Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Inherited from

ChunkedFileReader.json


ldjson()

protected ldjson(incomingData, slice): Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Defined in: base/chunked-file-reader.ts:320

Parameters

ParameterType
incomingDatastring
sliceFileSlice

Returns

Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Inherited from

ChunkedFileReader.ldjson


raw()

protected raw(incomingData, slice): Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Defined in: base/chunked-file-reader.ts:224

Parameters

ParameterType
incomingDatastring
sliceFileSlice

Returns

Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Inherited from

ChunkedFileReader.raw


read()

read(slice): Promise<DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>[]>

Defined in: base/chunked-file-reader.ts:334

Parameters

ParameterType
sliceFileSlice

Returns

Promise<DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>[]>

Inherited from

ChunkedFileReader.read


tsv()

protected tsv(incomingData, slice): Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Defined in: base/chunked-file-reader.ts:288

Parameters

ParameterType
incomingDatastring
sliceFileSlice

Returns

Promise<(null | DataEntity<Record<string, any>, _DataEntityMetadata<Record<string, any>>>)[]>

Inherited from

ChunkedFileReader.tsv