これらのクエリを Azure ポータルで使用する方法については、Log Analytics のチュートリアルを参照してください。 REST API については、「 Query」を参照してください。
DAG の種類と DAG 実行の要約統計
指定された期間内での各DAGタイプのDAG実行回数
OEPAirFlowTask
| extend ResourceName = tostring(split(_ResourceId , '/')[-1])
// | where ResourceName == "<the name of ADME instance>" // to filter on resourceName replace <...> and uncomment line
| distinct DagName, CorrelationId // correlationId is same as runId - we have created a duplicate for consistency in search across logs of all services
| sort by DagName asc
すべての DAG 実行の関連付け ID
指定された期間内に発生したすべてのDAGタイプのDAG実行の相関ID
OEPAirFlowTask
| extend ResourceName = tostring(split(_ResourceId , '/')[-1])
// | where ResourceName == "<the name of ADME instance>" // to filter on resourceName replace <...> and uncomment line
| distinct DagName, CorrelationId // correlationId is same as runId - we have created a duplicate for consistency in search across logs of all services
| summarize count() by DagName
DAG実行のログ
特定のAirFlow DAGランのログを、correlationIdと時間範囲を指定して取得します。
OEPAirFlowTask
| extend ResourceName = tostring(split(_ResourceId , '/')[-1])
// | where ResourceName == "<the name of ADME instance>" // to filter on resourceName replace <...> and uncomment line
// | where CorrelationId == "<DAG run's runId>" // to filter on correlationID replace <...> with correlationId (same as runId) - we have created a duplicate for to maintain consistency of column name across all services
| project TimeGenerated, DagName, LogLevel, DagTaskName, CodePath, Content
DAG 実行のエラー ログ
特定のAirFlow DAGの実行に対して、関連ID（correlationId）と時間範囲を指定してエラーログを取得します。
OEPAirFlowTask
| extend ResourceName = tostring(split(_ResourceId , '/')[-1])
// | where ResourceName == "<the name of ADME instance>" // to filter on resourceName replace <...> and uncomment line
// | where CorrelationId == "<DAG run's runId>" // to filter on correlationID replace <...> with correlationId (same as runId) - we have created a duplicate for to maintain consistency of column name across all services
| where LogLevel == "ERROR"
| project TimeGenerated, DagName, LogLevel, DagTaskName, CodePath, Content