Activity Runs - Query By Pipeline Run

Referensi

Service:: Data Factory

API Version:: 2018-06-01

Aktivitas kueri berjalan berdasarkan kondisi filter input.

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

Parameter URI

Name	In	Required	Type	Description
factoryName	path	True	string	Nama pabrik. Regex pattern: `^[A-Za-z0-9]+(?:-[A-Za-z0-9]+)*$`
resourceGroupName	path	True	string	Nama grup sumber daya. Regex pattern: `^[-\w\._]+$`
runId	path	True	string	Pengidentifikasi eksekusi alur.
subscriptionId	path	True	string	Pengidentifikasi langganan.
api-version	query	True	string	Versi API.

Isi Permintaan

Name	Required	Type	Description
lastUpdatedAfter	True	string	Waktu pada atau setelah peristiwa eksekusi diperbarui dalam format 'ISO 8601'.
lastUpdatedBefore	True	string	Waktu pada atau sebelum peristiwa eksekusi diperbarui dalam format 'ISO 8601'.
continuationToken		string	Token kelanjutan untuk mendapatkan halaman hasil berikutnya. Null untuk halaman pertama.
filters		RunQueryFilter[]	Daftar filter.
orderBy		RunQueryOrderBy[]	Daftar opsi OrderBy.

Respons

Name	Type	Description
200 OK	ActivityRunsQueryResponse	OK.
Other Status Codes	CloudError	Respons kesalahan yang diterima dari layanan Azure Data Factory.

Keamanan

azure_auth

Azure Active Directory Flow OAuth2.

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

Scopes

Name	Description
user_impersonation	meniru akun pengguna Anda

Contoh

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"
}

import com.azure.core.util.Context;
import com.azure.resourcemanager.datafactory.models.RunFilterParameters;
import java.time.OffsetDateTime;

/** Samples for ActivityRuns QueryByPipelineRun. */
public final class Main {
    /*
     * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/ActivityRuns_QueryByPipelineRun.json
     */
    /**
     * Sample code: ActivityRuns_QueryByPipelineRun.
     *
     * @param manager Entry point to DataFactoryManager.
     */
    public static void activityRunsQueryByPipelineRun(
        com.azure.resourcemanager.datafactory.DataFactoryManager manager) {
        manager
            .activityRuns()
            .queryByPipelineRunWithResponse(
                "exampleResourceGroup",
                "exampleFactoryName",
                "2f7fdb90-5df1-4b8e-ac2f-064cfa58202b",
                new RunFilterParameters()
                    .withLastUpdatedAfter(OffsetDateTime.parse("2018-06-16T00:36:44.3345758Z"))
                    .withLastUpdatedBefore(OffsetDateTime.parse("2018-06-16T00:49:48.3686473Z")),
                Context.NONE);
    }
}

Read this SDK documentation on how to add the SDK to your project and authenticate.

package armdatafactory_test

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/datafactory/armdatafactory"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/tree/main/specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/ActivityRuns_QueryByPipelineRun.json
func ExampleActivityRunsClient_QueryByPipelineRun() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	client, err := armdatafactory.NewActivityRunsClient("12345678-1234-1234-1234-12345678abc", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := client.QueryByPipelineRun(ctx,
		"exampleResourceGroup",
		"exampleFactoryName",
		"2f7fdb90-5df1-4b8e-ac2f-064cfa58202b",
		armdatafactory.RunFilterParameters{
			LastUpdatedAfter:  to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2018-06-16T00:36:44.3345758Z"); return t }()),
			LastUpdatedBefore: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2018-06-16T00:49:48.3686473Z"); return t }()),
		},
		nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// TODO: use response item
	_ = res
}

Read this SDK documentation on how to add the SDK to your project and authenticate.

const { DataFactoryManagementClient } = require("@azure/arm-datafactory");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Query activity runs based on input filter conditions.
 *
 * @summary Query activity runs based on input filter conditions.
 * x-ms-original-file: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/ActivityRuns_QueryByPipelineRun.json
 */
async function activityRunsQueryByPipelineRun() {
  const subscriptionId = "12345678-1234-1234-1234-12345678abc";
  const resourceGroupName = "exampleResourceGroup";
  const factoryName = "exampleFactoryName";
  const runId = "2f7fdb90-5df1-4b8e-ac2f-064cfa58202b";
  const filterParameters = {
    lastUpdatedAfter: new Date("2018-06-16T00:36:44.3345758Z"),
    lastUpdatedBefore: new Date("2018-06-16T00:49:48.3686473Z"),
  };
  const credential = new DefaultAzureCredential();
  const client = new DataFactoryManagementClient(credential, subscriptionId);
  const result = await client.activityRuns.queryByPipelineRun(
    resourceGroupName,
    factoryName,
    runId,
    filterParameters
  );
  console.log(result);
}

activityRunsQueryByPipelineRun().catch(console.error);

Read this SDK documentation on how to add the SDK to your project and authenticate.

Sample Response

Status code:: 200

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

Response Body

{
  "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"
    }
  ]
}

Definisi

ActivityRun	Informasi tentang aktivitas yang dijalankan dalam alur.
ActivityRunsQueryResponse	Aktivitas daftar berjalan.
CloudError	Objek yang menentukan struktur respons kesalahan Azure Data Factory.
RunFilterParameters	Parameter kueri untuk mencantumkan eksekusi.
RunQueryFilter	Opsi filter kueri untuk mencantumkan eksekusi.
RunQueryFilterOperand	Nama parameter yang akan digunakan untuk filter. Operan yang diizinkan untuk menjalankan alur kueri adalah PipelineName, RunStart, RunEnd dan Status; untuk mengkueri eksekusi aktivitas adalah ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType dan Status, dan untuk mengkueri eksekusi pemicu adalah TriggerName, TriggerRunTimestamp, dan Status.
RunQueryFilterOperator	Operator yang akan digunakan untuk filter.
RunQueryOrder	Urutan pengurutan parameter.
RunQueryOrderBy	Objek untuk menyediakan urutan berdasarkan opsi untuk mencantumkan eksekusi.
RunQueryOrderByField	Nama parameter yang akan digunakan untuk urutan berdasarkan. Parameter yang diizinkan untuk diurutkan menurut untuk eksekusi alur adalah PipelineName, RunStart, RunEnd dan Status; untuk eksekusi aktivitas adalah ActivityName, ActivityRunStart, ActivityRunEnd dan Status; untuk eksekusi pemicu adalah TriggerName, TriggerRunTimestamp, dan Status.

ActivityRun

Informasi tentang aktivitas yang dijalankan dalam alur.

Name	Type	Description
activityName	string	Nama aktivitas.
activityRunEnd	string	Waktu akhir aktivitas berjalan dalam format 'ISO 8601'.
activityRunId	string	Id eksekusi aktivitas.
activityRunStart	string	Waktu mulai aktivitas berjalan dalam format 'ISO 8601'.
activityType	string	Jenis aktivitas.
durationInMs	integer	Durasi eksekusi aktivitas.
error	object	Kesalahan jika ada dari aktivitas yang dijalankan.
input	object	Input untuk aktivitas.
linkedServiceName	string	Nama layanan tertaut komputasi.
output	object	Output untuk aktivitas.
pipelineName	string	Nama alur.
pipelineRunId	string	Id eksekusi alur.
status	string	Status eksekusi aktivitas.

ActivityRunsQueryResponse

Aktivitas daftar berjalan.

Name	Type	Description
continuationToken	string	Token kelanjutan untuk mendapatkan halaman hasil berikutnya, jika ada hasil yang tersisa, null sebaliknya.
value	ActivityRun[]	Daftar eksekusi aktivitas.

CloudError

Objek yang menentukan struktur respons kesalahan Azure Data Factory.

Name	Type	Description
error.code	string	Kode Kesalahan.
error.details	CloudError[]	Array dengan detail kesalahan tambahan.
error.message	string	Pesan kesalahan.
error.target	string	Nama/jalur properti dalam permintaan yang terkait dengan kesalahan.

RunFilterParameters

Parameter kueri untuk mencantumkan eksekusi.

Name	Type	Description
continuationToken	string	Token kelanjutan untuk mendapatkan halaman hasil berikutnya. Null untuk halaman pertama.
filters	RunQueryFilter[]	Daftar filter.
lastUpdatedAfter	string	Waktu pada atau setelah peristiwa eksekusi diperbarui dalam format 'ISO 8601'.
lastUpdatedBefore	string	Waktu pada atau sebelum peristiwa eksekusi diperbarui dalam format 'ISO 8601'.
orderBy	RunQueryOrderBy[]	Daftar opsi OrderBy.

RunQueryFilter

Opsi filter kueri untuk mencantumkan eksekusi.

Name	Type	Description
operand	RunQueryFilterOperand	Nama parameter yang akan digunakan untuk filter. Operan yang diizinkan untuk menjalankan alur kueri adalah PipelineName, RunStart, RunEnd dan Status; untuk mengkueri eksekusi aktivitas adalah ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType dan Status, dan untuk mengkueri eksekusi pemicu adalah TriggerName, TriggerRunTimestamp, dan Status.
operator	RunQueryFilterOperator	Operator yang akan digunakan untuk filter.
values	string[]	Daftar nilai filter.

RunQueryFilterOperand

Nama parameter yang akan digunakan untuk filter. Operan yang diizinkan untuk menjalankan alur kueri adalah PipelineName, RunStart, RunEnd dan Status; untuk mengkueri eksekusi aktivitas adalah ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType dan Status, dan untuk mengkueri eksekusi pemicu adalah TriggerName, TriggerRunTimestamp, dan Status.

Name	Type	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

Operator yang akan digunakan untuk filter.

Name	Type	Description
Equals	string
In	string
NotEquals	string
NotIn	string

RunQueryOrder

Urutan pengurutan parameter.

Name	Type	Description
ASC	string
DESC	string

RunQueryOrderBy

Objek untuk menyediakan urutan berdasarkan opsi untuk mencantumkan eksekusi.

Name	Type	Description
order	RunQueryOrder	Urutan pengurutan parameter.
orderBy	RunQueryOrderByField	Nama parameter yang akan digunakan untuk urutan berdasarkan. Parameter yang diizinkan untuk diurutkan menurut untuk eksekusi alur adalah PipelineName, RunStart, RunEnd dan Status; untuk eksekusi aktivitas adalah ActivityName, ActivityRunStart, ActivityRunEnd dan Status; untuk eksekusi pemicu adalah TriggerName, TriggerRunTimestamp, dan Status.

RunQueryOrderByField

Nama parameter yang akan digunakan untuk urutan berdasarkan. Parameter yang diizinkan untuk diurutkan menurut untuk eksekusi alur adalah PipelineName, RunStart, RunEnd dan Status; untuk eksekusi aktivitas adalah ActivityName, ActivityRunStart, ActivityRunEnd dan Status; untuk eksekusi pemicu adalah TriggerName, TriggerRunTimestamp, dan Status.

Name	Type	Description
ActivityName	string
ActivityRunEnd	string
ActivityRunStart	string
PipelineName	string
RunEnd	string
RunStart	string
Status	string
TriggerName	string
TriggerRunTimestamp	string