
Azure Sentinel Query
CertifiedQuery Microsoft Sentinel logs with KQL
Azure Sentinel Query
Query Microsoft Sentinel logs with KQL
Queries the Log Analytics workspace backing Sentinel. Returns the primary result table with column metadata. Partial query errors fail the task. The Azure SDK may materialize the response before results are stored.
type: io.kestra.plugin.azure.sentinel.QueryExamples
Store recent security alerts
id: sentinel_query
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.azure.sentinel.Query
tenantId: "{{ secret('AZURE_TENANT_ID') }}"
clientId: "{{ secret('AZURE_CLIENT_ID') }}"
clientSecret: "{{ secret('AZURE_CLIENT_SECRET') }}"
workspaceId: "{{ secret('AZURE_LOG_ANALYTICS_WORKSPACE_ID') }}"
query: SecurityAlert | take 100
timespan: P1D
serverTimeout: PT3M
fetchType: STORE
Properties
query *string
KQL query
Kusto Query Language expression executed against the workspace.
tenantId *string
Azure AD tenant ID (GUID)
workspaceId *string
Log Analytics workspace ID
The workspace customer ID (GUID), not its ARM resource ID or workspace 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
{}1150clientId string
Client ID of the Azure AD application
Application (client) ID used for service principal authentication.
clientSecret string
Client secret for the Azure AD application
Secret value associated with the client ID; store in a Kestra secret.
fetchType string
STORESTOREFETCHFETCH_ONENONEResult fetching mode
STORE writes ION to internal storage, FETCH returns all rows, and FETCH_ONE returns the first row. Other modes are unsupported.
logAnalyticsEndpoint string
https://api.loganalytics.ioLog Analytics endpoint
Base URL of the Log Analytics query API. Defaults to https://api.loganalytics.io (public cloud).
Override it for sovereign clouds, for example https://api.loganalytics.us (Azure Government) or
https://api.loganalytics.azure.cn (Azure China). The access token scope is derived
from this endpoint. Microsoft Entra sign-in uses the public authority unless the worker sets the
AZURE_AUTHORITY_HOST environment variable, for example https://login.microsoftonline.us.
pemCertificate string
PEM-encoded certificate content for client authentication
PEM text for certificate-based auth; alternative to clientSecret.
serverTimeout string
PT3MServer timeout
Positive ISO-8601 duration, at most PT10M. Defaults to PT3M.
timespan string
PT24HQuery timespan
Positive ISO-8601 look-back duration. Defaults to P1D.
Outputs
columns array
Primary result table columns
io.kestra.plugin.azure.sentinel.Query-Column
Column name
Kusto column type
count integer
Number of returned or stored rows
row object
First row
Present for nonempty FETCH_ONE results.
rows array
All rows
Present for FETCH.
uri string
uriStored ION URI
Present for STORE.