Alibaba Cloud Copy
CertifiedCopy an object within OSS
Alibaba Cloud Copy
Copy an object within OSS
Copies an object to another key, optionally in another bucket of the same region and account, and can delete the source afterwards to move it. The copy is a single request, so it is limited to objects of at most 1 GB, which is checked before copying. If the source cannot be deleted after a successful copy, the task fails with a message saying the copy exists.
type: io.kestra.plugin.alibaba.oss.CopyExamples
Copy an object, then remove the source to move it
id: oss_copy
namespace: company.team
tasks:
- id: move
type: io.kestra.plugin.alibaba.oss.Copy
accessKeyId: "{{ secret('ALIBABA_ACCESS_KEY_ID') }}"
accessKeySecret: "{{ secret('ALIBABA_ACCESS_KEY_SECRET') }}"
region: cn-hangzhou
bucket: my-bucket
key: landing/data.csv
destinationKey: archive/data.csv
delete: true
Properties
accessKeyId *string
AccessKey ID
The AccessKey ID used to authenticate against Alibaba Cloud.
accessKeySecret *string
AccessKey secret
The AccessKey secret paired with the AccessKey ID.
bucket *string
Bucket
The name of the OSS bucket.
destinationKey *string
Destination object key
The key of the copy. It must differ from the source when the bucket is the same.
key *string
Source object key
The key of the object to copy, in bucket.
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150delete booleanstring
falseDelete the source
Delete the source object once it is copied, which moves it.
destinationBucket string
Destination bucket
The bucket to copy to. Defaults to bucket.
endpointOverride string
Endpoint override
Custom http or https endpoint URL. When set, it takes precedence over the endpoint derived from region.
pathStyleAccess booleanstring
falsePath-style access
Address buckets as <endpoint>/<bucket> instead of <bucket>.<endpoint>. Useful with custom endpoints such as a local emulator.
region string
Region
The Alibaba Cloud region ID, for example cn-hangzhou. The service endpoint is derived from it unless endpointOverride is set.
securityToken string
Security token
Optional Security Token Service (STS) token, required when using temporary credentials.
Outputs
bucket string
Bucket of the copy
etag string
ETag of the copy
key string
Key of the copy
