@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
Parameter | Type |
---|---|
client | S3Client |
config | Omit <ReaderConfig , "size" > |
logger | Logger |
Returns
S3Fetcher
Overrides
Properties
Property | Modifier | Type | Inherited from | Defined in |
---|---|---|---|---|
bucket | readonly | string | - | s3/s3-fetcher.ts:9 |
client | protected | S3Client | - | s3/s3-fetcher.ts:8 |
compressor | public | Compressor | ChunkedFileReader .compressor | base/chunked-file-reader.ts:74 |
filePerSlice | protected | boolean | ChunkedFileReader .filePerSlice | base/chunked-file-reader.ts:83 |
logger | public | Logger | ChunkedFileReader .logger | base/chunked-file-reader.ts:73 |
Accessors
format
Get Signature
get format():
Format
Defined in: base/chunked-file-reader.ts:127
Returns
Inherited from
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
Parameter | Type |
---|---|
incomingData | string |
slice | FileSlice |
Returns
Promise
<(null
| DataEntity
<Record
<string
, any
>, _DataEntityMetadata
<Record
<string
, any
>>>)[]>
Inherited from
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
Parameter | Type |
---|---|
slice | FileSlice |
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
getMargin()
protected
getMargin(slice
,delimiter
):Promise
<string
>
Defined in: base/chunked-file-reader.ts:200
Parameters
Parameter | Type |
---|---|
slice | FileSlice |
delimiter | string |
Returns
Promise
<string
>
Inherited from
json()
protected
json(incomingData
,slice
):Promise
<(null
|DataEntity
<Record
<string
,any
>,_DataEntityMetadata
<Record
<string
,any
>>>)[]>
Defined in: base/chunked-file-reader.ts:294
Parameters
Parameter | Type |
---|---|
incomingData | string |
slice | FileSlice |
Returns
Promise
<(null
| DataEntity
<Record
<string
, any
>, _DataEntityMetadata
<Record
<string
, any
>>>)[]>
Inherited from
ldjson()
protected
ldjson(incomingData
,slice
):Promise
<(null
|DataEntity
<Record
<string
,any
>,_DataEntityMetadata
<Record
<string
,any
>>>)[]>
Defined in: base/chunked-file-reader.ts:320
Parameters
Parameter | Type |
---|---|
incomingData | string |
slice | FileSlice |
Returns
Promise
<(null
| DataEntity
<Record
<string
, any
>, _DataEntityMetadata
<Record
<string
, any
>>>)[]>
Inherited from
raw()
protected
raw(incomingData
,slice
):Promise
<(null
|DataEntity
<Record
<string
,any
>,_DataEntityMetadata
<Record
<string
,any
>>>)[]>
Defined in: base/chunked-file-reader.ts:224
Parameters
Parameter | Type |
---|---|
incomingData | string |
slice | FileSlice |
Returns
Promise
<(null
| DataEntity
<Record
<string
, any
>, _DataEntityMetadata
<Record
<string
, any
>>>)[]>
Inherited from
read()
read(
slice
):Promise
<DataEntity
<Record
<string
,any
>,_DataEntityMetadata
<Record
<string
,any
>>>[]>
Defined in: base/chunked-file-reader.ts:334
Parameters
Parameter | Type |
---|---|
slice | FileSlice |
Returns
Promise
<DataEntity
<Record
<string
, any
>, _DataEntityMetadata
<Record
<string
, any
>>>[]>
Inherited from
tsv()
protected
tsv(incomingData
,slice
):Promise
<(null
|DataEntity
<Record
<string
,any
>,_DataEntityMetadata
<Record
<string
,any
>>>)[]>
Defined in: base/chunked-file-reader.ts:288
Parameters
Parameter | Type |
---|---|
incomingData | string |
slice | FileSlice |
Returns
Promise
<(null
| DataEntity
<Record
<string
, any
>, _DataEntityMetadata
<Record
<string
, any
>>>)[]>