Alibaba Cloud Query
CertifiedExecute a MaxCompute SQL query
Alibaba Cloud Query
Execute a MaxCompute SQL query
Runs a SQL statement on Alibaba Cloud MaxCompute and retrieves or stores the result set. Supports cancellation via instance termination.
type: io.kestra.plugin.alibaba.maxcompute.QueryExamples
Run a MaxCompute query and store the result
id: maxcompute_query
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.alibaba.maxcompute.Query
accessKeyId: "{{ secret('ALIBABA_ACCESS_KEY_ID') }}"
accessKeySecret: "{{ secret('ALIBABA_ACCESS_KEY_SECRET') }}"
region: cn-shanghai
project: analytics
sql: |
SELECT region, SUM(amount) AS total
FROM orders
WHERE ds = '{{ now() | date('yyyyMMdd') }}'
GROUP BY region
fetchType: STORE
Execute a query and fetch rows
id: maxcompute_fetch
namespace: company.team
tasks:
- id: fetch_data
type: io.kestra.plugin.alibaba.maxcompute.Query
accessKeyId: "{{ secret('ALIBABA_ACCESS_KEY_ID') }}"
accessKeySecret: "{{ secret('ALIBABA_ACCESS_KEY_SECRET') }}"
region: cn-hangzhou
project: my_project
sql: "SELECT id, name FROM users LIMIT 100"
fetchType: FETCH
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.
project *string
Project
The MaxCompute project name.
sql *string
SQL query
The SQL query to execute.
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
{}1150endpointOverride string
Endpoint override
Custom http or https endpoint URL. When set, it takes precedence over the endpoint derived from region.
fetchType string
NONESTOREFETCHFETCH_ONENONEResult handling mode
FETCH_ONE, FETCH, STORE, or NONE. Defaults to NONE.
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.
tunnelEndpoint string
Tunnel endpoint override
Custom tunnel endpoint URL. If omitted, default tunnel routing is used.
Outputs
instanceId string
The MaxCompute instance ID
row object
Map containing the first row
Only populated if fetchType is FETCH_ONE
rows array
List containing fetched rows
Only populated if fetchType is FETCH
size integer
The total number of rows returned
uri string
uriThe URI of the stored result in internal storage
Only populated if fetchType is STORE
