Alibaba Cloud Push
CertifiedPush logs to Alibaba Cloud Simple Log Service (SLS)
Alibaba Cloud Push
Push logs to Alibaba Cloud Simple Log Service (SLS)
Writes log records to an SLS Logstore from an inline list of maps, a single map, or a file in Kestra internal storage.
type: io.kestra.plugin.alibaba.sls.PushExamples
Push inline logs to SLS
id: sls_push
namespace: company.team
tasks:
- id: push_logs
type: io.kestra.plugin.alibaba.sls.Push
accessKeyId: "{{ secret('ALIBABA_ACCESS_KEY_ID') }}"
accessKeySecret: "{{ secret('ALIBABA_ACCESS_KEY_SECRET') }}"
region: cn-hangzhou
project: ops-logs
logstore: app-events
from:
- level: INFO
message: Flow finished
flow: "{{ flow.id }}"
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.
from *object
Source data
Inline map, list of maps, JSON string, or URI of an Ion file in Kestra internal storage.
logstore *string
Logstore
The SLS Logstore name.
project *string
Project
The SLS project name.
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.
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.
source string
kestraSource
The log source. Defaults to 'kestra'.
topic string
Topic
The log topic.
Outputs
count integer
The total number of log records pushed
