Azure Data Factory ve Synapse Analytics'te Bekleme etkinliği yürütme

İşlem hattında Bekleme etkinliğini kullandığınızda, işlem hattı izleyen etkinlikleri yürütmeye devam etmeden önce belirtilen süre kadar bekler.

ŞUNLARA UYGULANIR: Azure Data Factory Azure Synapse Analytics

İpucu

Microsoft Fabric'te Data Factory'deki eşdeğer etkinlik için bkz. Bekleme etkinliği.

Kullanıcı arabirimiyle Bekleme etkinliği oluşturma

İşlem hattında Bekleme etkinliği kullanmak için aşağıdaki adımları tamamlayın:

  1. İşlem hattı Etkinlikleri bölmesinde Bekle'yi arayın ve bekleme etkinliğini işlem hattı tuvaline sürükleyin.

  2. Tuval üzerinde yeni Bekleme Etkinliği henüz seçili değilse, önce onu ve ardından Ayarlar sekmesini seçerek ayrıntılarını düzenleyin.

    Bekleme etkinliğinin kullanıcı arabirimini gösterir.

  3. Etkinliğin beklemesi için bir saniye sayısı girin. Bu sabit bir sayı veya dinamik ifadelerin, işlevlerin, sistem değişkenlerinin veya diğer etkinliklerden gelen çıkışların herhangi bir bileşimi olabilir.

Sözdizimi

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

Tür özellikleri

Özellik Açıklama İzin verilen değerler Zorunlu
Adı Etkinliğin Wait adı. String Yes
Tip Bekle olarak ayarlanmalıdır. String Yes
beklemeSüresiSaniyeCinsinden İşlem hattı işlemeye devam etmeden önce bekleyeceği saniye sayısı. Tamsayı Yes

Örnek

Not

Bu bölümde, işlem hattını çalıştırmak için JSON tanımları ve örnek PowerShell komutları sağlanır. Azure PowerShell ve JSON tanımlarını kullanarak işlem hattı oluşturmaya yönelik adım adım yönergeler içeren bir kılavuz için bkz. tutorial: Azure PowerShell kullanarak veri fabrikası oluşturma.

Bekleme etkinliği içeren işlem hattı

Bu örnekte işlem hattının iki etkinliği vardır: Until ve Wait. Bekleme etkinliği bir saniye bekleyecek şekilde yapılandırılmıştır. İşlem hattı, web etkinliğini her çalıştırma arasında bir saniye bekleme süresiyle bir döngüde çalıştırır.

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

İlgili içerik

Desteklenen diğer denetim akışı etkinliklerine bakın:

  • Last updated on