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 |
---|---|---|---|---|
factory
|
path | True |
string |
Fabrika adı. Regex pattern: |
resource
|
path | True |
string |
Kaynak grubu adı. Regex pattern: |
run
|
path | True |
string |
İşlem hattı çalıştırma tanımlayıcısı. |
subscription
|
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 |
Filtre listesi. |
||
orderBy |
OrderBy seçeneğinin listesi. |
Yanıtlar
Name | Tür | Description |
---|---|---|
200 OK |
Tamam ögesini seçin. |
|
Other Status Codes |
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 |
---|---|
Activity |
İşlem hattında bir etkinlik çalıştırması hakkında bilgi. |
Activity |
Liste etkinliği çalışır. |
Cloud |
Azure Data Factory hata yanıtının yapısını tanımlayan nesne. |
Run |
Çalıştırmaları listelemek için sorgu parametreleri. |
Run |
Çalıştırmaları listelemek için sorgu filtresi seçeneği. |
Run |
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. |
Run |
Filtre için kullanılacak işleç. |
Run |
Parametrenin sıralama düzeni. |
Run |
Çalıştırmaları listelemek için sıralama ölçütü seçenekleri sağlayan bir nesne. |
Run |
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 |
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 |
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 |
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 |
OrderBy seçeneğinin listesi. |
RunQueryFilter
Çalıştırmaları listelemek için sorgu filtresi seçeneği.
Name | Tür | Description |
---|---|---|
operand |
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 |
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 |
Parametrenin sıralama düzeni. |
|
orderBy |
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 |