Bagikan melalui


Menjalankan aktivitas Tunggu di Azure Data Factory dan Synapse Analytics

Saat Anda menggunakan aktivitas Tunggu di alur, alur menunggu periode waktu yang ditentukan sebelum melanjutkan dengan eksekusi aktivitas berikutnya.

Azure Data Factory Azure Synapse Analytics

Petunjuk

Data Factory di Microsoft Fabric adalah generasi Azure Data Factory berikutnya, dengan arsitektur yang lebih sederhana, AI bawaan, dan fitur baru. Jika Anda baru menggunakan integrasi data, mulailah dengan Fabric Data Factory. Beban kerja ADF yang ada dapat ditingkatkan ke Fabric untuk mengakses kemampuan baru di seluruh ilmu data, analitik real time, dan pelaporan.

Membuat aktivitas Wait dengan UI

Untuk menggunakan aktivitas Tunggu dalam alur, selesaikan langkah-langkah berikut:

  1. Cari Tunggu di panel Aktivitas alur, dan seret aktivitas Tunggu ke kanvas alur.

  2. Pilih aktivitas Tunggu baru di kanvas jika belum dipilih, dan tab Pengaturan, untuk mengedit detail aktivitasnya.

    Menampilkan UI untuk aktivitas Tunggu.

  3. Masukkan beberapa detik untuk durasi tunggu aktivitas tersebut. Ini dapat berupa angka literal, atau kombinasi ekspresi dinamis, fungsi, variabel sistem, atau output dari aktivitas lainnya.

Sintaks

{
    "name": "MyWaitActivity",
    "type": "Wait",
    "typeProperties": {
        "waitTimeInSeconds": 1
    }
}

Properti jenis

Properti Deskripsi Nilai yang diizinkan Wajib
nama Nama Waitaktivitas. String Ya
jenis Harus diatur ke Tunggu. String Ya
waktuTungguDalamDetik Jumlah detik yang ditunggu alur sebelum melanjutkan pemrosesan. Bilangan bulat Ya

Contoh

Catatan

Bagian ini menyediakan definisi JSON dan sampel perintah PowerShell untuk menjalankan alur. Untuk panduan dengan instruksi langkah demi langkah untuk membuat alur dengan menggunakan definisi Azure PowerShell dan JSON, lihat tutorial: membuat pabrik data dengan menggunakan Azure PowerShell.

Alur dengan aktivitas Tunggu

Dalam contoh ini, alur memiliki dua aktivitas: Hingga dan Tunggu. Aktivitas Tunggu dikonfigurasi untuk menunggu selama satu detik. Alur mengeksekusi aktivitas Web dalam perulangan dengan waktu tunggu satu detik di antara setiap eksekusi.

{
    "name": "DoUntilPipeline",
    "properties": {
        "activities": [
            {
                "type": "Until",
                "typeProperties": {
                    "expression": {
                        "value": "@equals('Failed', coalesce(body('MyUnauthenticatedActivity')?.status, actions('MyUnauthenticatedActivity')?.status, 'null'))",
                        "type": "Expression"
                    },
                    "timeout": "00:10:00",
                    "activities": [
                        {
                            "name": "MyUnauthenticatedActivity",
                            "type": "WebActivity",
                            "typeProperties": {
                                "method": "get",
                                "url": "https://www.fake.com/",
                                "headers": {
                                    "Content-Type": "application/json"
                                }
                            },
                            "dependsOn": [
                                {
                                    "activity": "MyWaitActivity",
                                    "dependencyConditions": [ "Succeeded" ]
                                }
                            ]
                        },
                        {
                            "type": "Wait",
                            "typeProperties": {
                                "waitTimeInSeconds": 1
                            },
                            "name": "MyWaitActivity"
                        }
                    ]
                },
                "name": "MyUntilActivity"
            }
        ]
    }
}

Lihat aktivitas alur kontrol yang didukung lainnya: