Aracılığıyla paylaş


Azure Data Factory ve Azure Synapse Analytics tarafından desteklenen sistem değişkenleri

ŞUNLAR İÇİN GEÇERLİDİR: Azure Data Factory Azure Synapse Analytics

Tip

Kuruluşlar için hepsi bir arada analiz çözümü olan Microsoft Fabric'te Data Factory'yi deneyin. Microsoft Fabric , veri taşımadan veri bilimine, gerçek zamanlı analize, iş zekasına ve raporlamaya kadar her şeyi kapsar. Yeni bir deneme sürümünü ücretsiz olarak başlatmayı öğrenin!

Bu makalede Azure Data Factory ve Azure Synapse tarafından desteklenen sistem değişkenleri açıklanmaktadır. Bu değişkenleri, iki hizmette de varlık tanımlarken ifadelerde kullanabilirsiniz.

Pipeline scope

Bu sistem değişkenlerine işlem hattı JSON'un herhangi bir yerinde başvurulabilir.

Variable Name Description
@pipeline().DataFactory İşlem hattı çalıştırmasının çalıştığı verilerin adı veya Synapse çalışma alanının adı
@pipeline().Pipeline İşlem hattının adı
@pipeline().RunId Belirli bir işlem hattı çalıştırmasının kimliği
@pipeline().TriggerType İşlem hattını çağıran tetikleyici türü (örneğin, , ScheduleTriggerBlobEventsTrigger). Desteklenen tetikleyici türlerini görmek için İşlem hattı yürütme ve tetikleyiciler'e bakın. tetikleyici türü Manual , işlem hattının el ile tetiklendiğini gösterir.
@pipeline().TriggerId İşlem hattını çağıran tetikleyicinin kimliği
@pipeline().TriggerName İşlem hattını çağıran tetikleyicinin adı
@pipeline().TriggerTime İşlem hattını çağıran tetikleyici çalıştırmasının zamanı. Bu, tetikleyicinin işlem hattı çalıştırmasını çağırmak için tetiklendiği zamandır ve tetikleyicinin zamanlanmış zamanından biraz farklı olabilir.
@pipeline().GroupId İşlem hattı çalıştırmasına ait olduğu grubun kimliği.
@pipeline()?.TriggeredByPipelineName Pipeline çalışmasını tetikleyen boru hattının adı. İşlem hattı çalıştırması bir ExecutePipeline etkinliği tarafından tetiklendiğinde geçerlidir. Başka durumlarda kullanıldığında Null olarak değerlendirin. Ardından soru işaretini not edin @pipeline()
@pipeline()?.TriggeredByPipelineRunId İşlem hattı çalıştırmasını tetikleyen işlem hattının çalıştırma kimliği. İşlem hattı çalıştırması bir ExecutePipeline etkinliği tarafından tetiklendiğinde geçerlidir. Başka durumlarda kullanıldığında Null olarak değerlendirin. Ardından soru işaretini not edin @pipeline()

Note

Tetikleyiciyle ilgili tarih/saat sistem değişkenleri (hem işlem hattı hem de tetikleyici kapsamlarında) UTC tarihlerini ISO 8601 biçiminde döndürür, örneğin. 2017-06-01T22:20:00.4061448Z

Tetikleyici kapsamını zamanlama

Bu sistem değişkenlerine ScheduleTrigger türünde tetikleyiciler için tetikleyici JSON'un herhangi bir yerinde başvurulabilir.

Variable Name Description
@trigger().scheduledTime Tetikleyicinin, işlem hattı çalışmasını başlatmak üzere zamanlandığı saat.
@trigger().startTime İşlem hattı çalıştırmasını çağırmak için tetikleyicinin tetiklendiği zaman. Bu, tetikleyicinin zamanlanan zamanından biraz farklı olabilir.

Atlayan pencere tetikleyici kapsamı

Bu sistem değişkenlerine TumblingWindowTrigger türünde tetikleyiciler için tetikleyici JSON'un herhangi bir yerinde başvurulabilir.

Variable Name Description
@trigger().outputs.windowStartTime Tetikleyici çalıştırmasıyla ilişkili zaman diliminin başlangıcı.
@trigger().outputs.windowEndTime Tetikleyici çalıştırmasıyla ilişkili zaman penceresinin sonu.
@trigger().scheduledTime Tetikleyicinin, işlem hattı çalışmasını başlatmak üzere zamanlandığı saat.
@trigger().startTime İşlem hattı çalıştırmasını çağırmak için tetikleyicinin tetiklendiği zaman. Bu, tetikleyicinin zamanlanan zamanından biraz farklı olabilir.

Depolama olayı tetikleyici kapsamı

Bu sistem değişkenlerine, BlobEventsTrigger türünde tetikleyiciler için tetikleyici JSON'un herhangi bir yerinde başvurulabilir.

Variable Name Description
@triggerBody().fileName Tetikleyicinin çalışmasını tetikleyen, oluşturulmuş veya silinmiş dosyanın adı.
@triggerBody().folderPath tarafından @triggerBody().fileNamebelirtilen dosyayı içeren klasörün yolu. Klasör yolunun ilk kesimi, Azure Blob Depolama kapsayıcısının adıdır.
@trigger().startTime İşlem hattı çalışmasını başlatmak için tetikleyicinin harekete geçtiği zaman.

Note

Azure Synapse Analytics'te işlem hattınızı ve tetikleyicinizi oluşturuyorsanız, parametre olarak @trigger().outputs.body.fileName ve @trigger().outputs.body.folderPath kullanmanız gerekir. Bu iki özellik blob bilgilerini yakalar. Bu özellikleri @triggerBody().fileName ve @triggerBody().folderPath yerine kullanın.

Özelleştirilmiş olay tetikleyici kapsamı

Bu sistem değişkenlerine, CustomEventsTrigger türünde tetikleyiciler için tetikleyici JSON'un herhangi bir yerinde başvurulabilir.

Note

Hizmet, özel olayların Azure Event Grid olay şemasıyla biçimlendirilmelerini bekler.

Variable Name Description
@triggerBody().event.eventType Özel Olay Tetikleyici çalışmasını tetikleyen olay türleri. Olay türü müşteri tanımlı bir alandır ve dize türündeki tüm değerleri alır.
@triggerBody().event.subject Tetikleyiciyi çalıştıran özel olayın konusu.
@triggerBody().event.data._keyName_ Özel olaydaki veri alanı, müşterinin ileti ve veri göndermek için kullanabileceği JSON blobundan ücretsizdir. Verilerdeki keyName'i kullanarak her alana başvurun. Örneğin, @triggerBody().event.data.callback veriler altında depolanan geri çağırma alanının değerini döndürür.
@trigger().startTime İşlem hattı çalışmasını başlatmak için tetikleyicinin harekete geçtiği zaman.

Note

Azure Synapse Analytics'te işlem hattınızı ve tetikleyicinizi oluşturuyorsanız parametre olarak kullanmanız @trigger().outputs.body.event gerekir. Bu özellik olay bilgilerini yakalar. kullanmak yerine bu özelliği kullanın @triggerBody().event.