Activity Runs - Query By Pipeline Run

Sorgu etkinliği, giriş filtresi koşullarına göre çalıştırılır.

POST https://management.azure.com/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DataFactory/factories/{factoryName}/pipelineruns/{runId}/queryActivityruns?api-version=2018-06-01

URI Parametreleri

Name İçinde Gerekli Tür Description
factoryName
path True

string

Fabrika adı.

Regex pattern: ^[A-Za-z0-9]+(?:-[A-Za-z0-9]+)*$

resourceGroupName
path True

string

Kaynak grubu adı.

Regex pattern: ^[-\w\._\(\)]+$

runId
path True

string

İşlem hattı çalıştırma tanımlayıcısı.

subscriptionId
path True

string

Abonelik tanımlayıcısı.

api-version
query True

string

API sürümü.

İstek Gövdesi

Name Gerekli Tür Description
lastUpdatedAfter True

string

Çalıştırma olayının 'ISO 8601' biçiminde güncelleştirildiği saat veya sonrasında.

lastUpdatedBefore True

string

Çalıştırma olayının 'ISO 8601' biçiminde güncelleştirildiği saat veya öncesinde.

continuationToken

string

Sonuçların sonraki sayfasını almak için devamlılık belirteci. İlk sayfa için null.

filters

RunQueryFilter[]

Filtre listesi.

orderBy

RunQueryOrderBy[]

OrderBy seçeneğinin listesi.

Yanıtlar

Name Tür Description
200 OK

ActivityRunsQueryResponse

Tamam ögesini seçin.

Other Status Codes

CloudError

Azure Data Factory hizmetinden alınan bir hata yanıtı.

Güvenlik

azure_auth

Azure Active Directory OAuth2 Flow.

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

Name Description
user_impersonation kullanıcı hesabınızın kimliğine bürünme

Örnekler

ActivityRuns_QueryByPipelineRun

Sample Request

POST https://management.azure.com/subscriptions/12345678-1234-1234-1234-12345678abc/resourceGroups/exampleResourceGroup/providers/Microsoft.DataFactory/factories/exampleFactoryName/pipelineruns/2f7fdb90-5df1-4b8e-ac2f-064cfa58202b/queryActivityruns?api-version=2018-06-01

{
  "lastUpdatedAfter": "2018-06-16T00:36:44.3345758Z",
  "lastUpdatedBefore": "2018-06-16T00:49:48.3686473Z"
}

Sample Response

Date: Sat, 16 Jun 2018 00:40:13 GMT
X-Content-Type-Options: nosniff
x-ms-ratelimit-remaining-subscription-writes: 1187
x-ms-request-id: 5465cf41-2e71-4ce6-8db4-9de1b92ffda9
x-ms-correlation-request-id: 5465cf41-2e71-4ce6-8db4-9de1b92ffda9
{
  "value": [
    {
      "activityRunEnd": "2018-06-16T00:38:11.5445431Z",
      "activityName": "ExampleForeachActivity",
      "activityRunStart": "2018-06-16T00:37:49.4804925Z",
      "activityType": "ForEach",
      "durationInMs": 22064,
      "retryAttempt": null,
      "error": {
        "errorCode": "",
        "message": "",
        "failureType": "",
        "target": "ExampleForeachActivity"
      },
      "activityRunId": "f30c5514-fb85-43ed-9fa4-768d42e58680",
      "input": {},
      "linkedServiceName": "",
      "output": {},
      "userProperties": {},
      "pipelineName": "examplePipeline",
      "pipelineRunId": "2f7fdb90-5df1-4b8e-ac2f-064cfa58202b",
      "status": "Succeeded"
    },
    {
      "activityRunEnd": "2018-06-16T00:38:07.4188923Z",
      "activityName": "ExampleCopyActivity",
      "activityRunStart": "2018-06-16T00:37:50.2460952Z",
      "activityType": "Copy",
      "durationInMs": 17172,
      "retryAttempt": null,
      "error": {
        "errorCode": "",
        "message": "",
        "failureType": "",
        "target": "ExampleCopyActivity"
      },
      "activityRunId": "a96678c8-7167-4f00-b629-afccfbad4e51",
      "input": {
        "source": {
          "type": "BlobSource"
        },
        "sink": {
          "type": "BlobSink"
        },
        "dataIntegrationUnits": 32
      },
      "linkedServiceName": "",
      "output": {
        "dataRead": 142000,
        "dataWritten": 142000,
        "filesRead": 1,
        "filesWritten": 1,
        "copyDuration": 6,
        "throughput": 23.112,
        "errors": [],
        "effectiveIntegrationRuntime": "DefaultIntegrationRuntime (East US)",
        "usedCloudDataMovementUnits": 4,
        "usedParallelCopies": 1,
        "executionDetails": [
          {
            "source": {
              "type": "AzureBlob"
            },
            "sink": {
              "type": "AzureBlob"
            },
            "status": "Succeeded",
            "start": "2018-06-16T00:37:50.68834Z",
            "duration": 6,
            "usedCloudDataMovementUnits": 4,
            "usedParallelCopies": 1,
            "detailedDurations": {
              "queuingDuration": 4,
              "transferDuration": 2
            }
          }
        ]
      },
      "userProperties": {},
      "pipelineName": "examplePipeline",
      "pipelineRunId": "2f7fdb90-5df1-4b8e-ac2f-064cfa58202b",
      "status": "Succeeded"
    }
  ]
}

Tanımlar

Name Description
ActivityRun

İşlem hattında bir etkinlik çalıştırması hakkında bilgi.

ActivityRunsQueryResponse

Liste etkinliği çalışır.

CloudError

Azure Data Factory hata yanıtının yapısını tanımlayan nesne.

RunFilterParameters

Çalıştırmaları listelemek için sorgu parametreleri.

RunQueryFilter

Çalıştırmaları listelemek için sorgu filtresi seçeneği.

RunQueryFilterOperand

Filtre için kullanılacak parametre adı. İşlem hattı çalıştırmalarını sorgulamak için izin verilen işlenenler PipelineName, RunStart, RunEnd ve Status şeklindedir; sorgu etkinlik çalıştırmaları ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType ve Status şeklindedir ve tetikleyici çalıştırmalarını sorgulamak için TriggerName, TriggerRunTimestamp ve Status'dır.

RunQueryFilterOperator

Filtre için kullanılacak işleç.

RunQueryOrder

Parametrenin sıralama düzeni.

RunQueryOrderBy

Çalıştırmaları listelemek için sıralama ölçütü seçenekleri sağlayan bir nesne.

RunQueryOrderByField

Sıralama ölçütü olarak kullanılacak parametre adı. İşlem hattı çalıştırmaları için sıralamaya göre izin verilen parametreler PipelineName, RunStart, RunEnd ve Status parametreleridir; etkinlik çalıştırmaları için ActivityName, ActivityRunStart, ActivityRunEnd ve Status; tetikleyici çalıştırmaları için TriggerName, TriggerRunTimestamp ve Status şeklindedir.

ActivityRun

İşlem hattında bir etkinlik çalıştırması hakkında bilgi.

Name Tür Description
activityName

string

Etkinliğin adı.

activityRunEnd

string

Etkinliğin bitiş saati 'ISO 8601' biçiminde çalışır.

activityRunId

string

Etkinlik çalıştırmasının kimliği.

activityRunStart

string

Etkinliğin başlangıç saati 'ISO 8601' biçiminde çalışır.

activityType

string

Etkinliğin türü.

durationInMs

integer

Etkinlik çalıştırmasının süresi.

error

object

Etkinlikten herhangi biri çalıştırılırsa hata.

input

object

Etkinliğin girişi.

linkedServiceName

string

İşlem bağlı hizmetinin adı.

output

object

Etkinliğin çıktısı.

pipelineName

string

İşlem hattının adı.

pipelineRunId

string

İşlem hattı çalıştırmasının kimliği.

status

string

Etkinlik çalıştırmasının durumu.

ActivityRunsQueryResponse

Liste etkinliği çalışır.

Name Tür Description
continuationToken

string

Kalan sonuçlar varsa bir sonraki sonuç sayfasını almaya yönelik devamlılık belirteci, aksi takdirde null olur.

value

ActivityRun[]

Etkinlik çalıştırmalarının listesi.

CloudError

Azure Data Factory hata yanıtının yapısını tanımlayan nesne.

Name Tür Description
error.code

string

Hata kodu.

error.details

CloudError[]

Ek hata ayrıntıları içeren dizi.

error.message

string

Hata iletisi.

error.target

string

Hatayla ilişkili istekteki özellik adı/yolu.

RunFilterParameters

Çalıştırmaları listelemek için sorgu parametreleri.

Name Tür Description
continuationToken

string

Sonuçların sonraki sayfasını almak için devamlılık belirteci. İlk sayfa için null.

filters

RunQueryFilter[]

Filtre listesi.

lastUpdatedAfter

string

Çalıştırma olayının 'ISO 8601' biçiminde güncelleştirildiği saat veya sonrasında.

lastUpdatedBefore

string

Çalıştırma olayının 'ISO 8601' biçiminde güncelleştirildiği saat veya öncesinde.

orderBy

RunQueryOrderBy[]

OrderBy seçeneğinin listesi.

RunQueryFilter

Çalıştırmaları listelemek için sorgu filtresi seçeneği.

Name Tür Description
operand

RunQueryFilterOperand

Filtre için kullanılacak parametre adı. İşlem hattı çalıştırmalarını sorgulamak için izin verilen işlenenler PipelineName, RunStart, RunEnd ve Status şeklindedir; sorgu etkinlik çalıştırmaları ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType ve Status şeklindedir ve tetikleyici çalıştırmalarını sorgulamak için TriggerName, TriggerRunTimestamp ve Status'dır.

operator

RunQueryFilterOperator

Filtre için kullanılacak işleç.

values

string[]

Filtre değerlerinin listesi.

RunQueryFilterOperand

Filtre için kullanılacak parametre adı. İşlem hattı çalıştırmalarını sorgulamak için izin verilen işlenenler PipelineName, RunStart, RunEnd ve Status şeklindedir; sorgu etkinlik çalıştırmaları ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType ve Status şeklindedir ve tetikleyici çalıştırmalarını sorgulamak için TriggerName, TriggerRunTimestamp ve Status'dır.

Name Tür Description
ActivityName

string

ActivityRunEnd

string

ActivityRunStart

string

ActivityType

string

LatestOnly

string

PipelineName

string

RunEnd

string

RunGroupId

string

RunStart

string

Status

string

TriggerName

string

TriggerRunTimestamp

string

RunQueryFilterOperator

Filtre için kullanılacak işleç.

Name Tür Description
Equals

string

In

string

NotEquals

string

NotIn

string

RunQueryOrder

Parametrenin sıralama düzeni.

Name Tür Description
ASC

string

DESC

string

RunQueryOrderBy

Çalıştırmaları listelemek için sıralama ölçütü seçenekleri sağlayan bir nesne.

Name Tür Description
order

RunQueryOrder

Parametrenin sıralama düzeni.

orderBy

RunQueryOrderByField

Sıralama ölçütü olarak kullanılacak parametre adı. İşlem hattı çalıştırmaları için sıralamaya göre izin verilen parametreler PipelineName, RunStart, RunEnd ve Status parametreleridir; etkinlik çalıştırmaları için ActivityName, ActivityRunStart, ActivityRunEnd ve Status; tetikleyici çalıştırmaları için TriggerName, TriggerRunTimestamp ve Status şeklindedir.

RunQueryOrderByField

Sıralama ölçütü olarak kullanılacak parametre adı. İşlem hattı çalıştırmaları için sıralamaya göre izin verilen parametreler PipelineName, RunStart, RunEnd ve Status parametreleridir; etkinlik çalıştırmaları için ActivityName, ActivityRunStart, ActivityRunEnd ve Status; tetikleyici çalıştırmaları için TriggerName, TriggerRunTimestamp ve Status şeklindedir.

Name Tür Description
ActivityName

string

ActivityRunEnd

string

ActivityRunStart

string

PipelineName

string

RunEnd

string

RunStart

string

Status

string

TriggerName

string

TriggerRunTimestamp

string