mirror of
https://github.com/diced/zipline.git
synced 2025-12-12 07:40:45 -08:00
@@ -64,7 +64,7 @@ export class S3Datasource extends Datasource {
|
|||||||
this.ensureReadWriteAccess();
|
this.ensureReadWriteAccess();
|
||||||
}
|
}
|
||||||
|
|
||||||
private key(path: string): string {
|
public key(path: string): string {
|
||||||
if (this.options.subdirectory) {
|
if (this.options.subdirectory) {
|
||||||
return this.options.subdirectory.endsWith('/')
|
return this.options.subdirectory.endsWith('/')
|
||||||
? this.options.subdirectory + path
|
? this.options.subdirectory + path
|
||||||
|
|||||||
@@ -152,7 +152,7 @@ async function main() {
|
|||||||
client: s3datasource.client,
|
client: s3datasource.client,
|
||||||
params: {
|
params: {
|
||||||
Bucket: s3datasource.options.bucket,
|
Bucket: s3datasource.options.bucket,
|
||||||
Key: file.filename,
|
Key: s3datasource.key(file.filename),
|
||||||
Body: bodyStream,
|
Body: bodyStream,
|
||||||
},
|
},
|
||||||
partSize: bytes(config.chunks.size),
|
partSize: bytes(config.chunks.size),
|
||||||
|
|||||||
Reference in New Issue
Block a user