Share via


İş çalıştırmaları hakkındaki bağlamı iş görevlerine geçirme

İş veya görev adı, çalıştırmanın tanımlayıcısı veya bir iş çalıştırmasının başlangıç saati gibi bir iş veya görev çalıştırması hakkında bağlam geçirmek için dinamik değer başvuruları kullanabilirsiniz. Dinamik değer başvuruları, iş görevi çalıştırıldığında uygun değerlerle değiştirilen şablonlu değişkenlerdir. Bir iş çalıştırıldığında, çift küme ayraçları ile çevrili görev parametresi değişkeni değiştirilir ve değerin parçası olarak eklenen isteğe bağlı bir dize değerine eklenir. Örneğin, herhangi bir iş kimliği 6 çalıştırması için değerine my-job-6 sahip adlı MyJobId bir parametre geçirmek için aşağıdaki görev parametresini ekleyin:

{
  "MyJobID": "my-job-{{job.id}}"
}

Çift küme ayraçlarının içeriği ifade olarak değerlendirilmez, bu nedenle çift küme ayraçlarında işlem veya işlev yapamazsınız.

Kullanıcı tarafından sağlanan tanımlayıcılar, örneğin, görev adları, görev değeri anahtarları veya özel karakterler içeren iş parametresi adları, tanımlayıcıların arka uçlarla (` ` ) çevrelenmesiyle kaçış noktası oluşturulmalıdır. Kaçış olmadan yalnızca alfasayısal ve alt çizgi karakterleri kullanılabilir.

{
  "VariableWithSpecialChars": "{{job.parameters.`param$@`}}"
}

Başvurulardaki söz dizimi hataları (örneğin, eksik bir küme ayracı) yoksayılır ve değer değişmez değer dizesi olarak değerlendirilir. Örneğin, {{my.value} dizesi "{{my.value}"olarak geçirilir. Ancak, bilinen bir ad alanına (örneğin, {{job.naem}}) ait geçersiz bir başvuru girilmesine izin verilmez. Kullanıcı arabirimine bilinen bir ad alanına ait geçersiz bir başvuru girilirse bir hata iletisi görüntülenir.

Görev tamamlandıktan sonra, çalıştırma ayrıntıları sayfasındaki Parametreler'in altında parametreler için çözümlenen değerleri görebilirsiniz.

Desteklenen değer başvuruları

Aşağıdaki dinamik değer başvuruları desteklenir:

Başvuru Açıklama
{{job.id}} İşe atanan benzersiz tanımlayıcı.
{{job.name}} İş çalıştırıldığında işin adı.
{{job.run_id}} İş çalıştırmasına atanan benzersiz tanımlayıcı.
{{job.repair_count}} Geçerli iş çalıştırması üzerindeki onarım denemelerinin sayısı.
{{job.start_time.[argument]}} İşin başlattığı saati (UTC saat diliminde) temel alan bir değer. Dönüş değeri seçeneğine argument bağlıdır. Bkz. Tarih ve saat değerleri için seçenekler.
{{job.parameters.[name]}} anahtarıyla [name]iş düzeyi parametresinin değeri.
{{job.trigger.type}} İşin tetikleyici türü çalıştırılır. Olası değerler , , onetime, file_arrivalrun_job_task, ve continuoustabledeğerleridirperiodic.
{{job.trigger.file_arrival.location}} Bu iş için bir dosya varış tetikleyicisi yapılandırıldıysa, depolama konumunun değeri.
{{job.trigger.time.[argument]}} İş çalıştırmasının tetiklendiği saate (UTC saat diliminde) göre bir değer, cron zamanlaması olan işler için en yakın dakikaya yuvarlanır. Dönüş değeri seçeneğine argument bağlıdır. Bkz. Tarih ve saat değerleri için seçenekler.
{{task.name}} Geçerli görevin adı.
{{task.run_id}} Geçerli görev çalıştırmasının benzersiz tanımlayıcısı.
{{task.execution_count}} Geçerli görevin çalışma sayısı (yeniden denemeler ve onarımlar dahil).
{{task.notebook_path}} Geçerli not defteri görevinin not defteri yolu.
{{tasks.[task_name].run_id}} Görev çalıştırmasına atanan benzersiz tanımlayıcı için [task_name]çalışır.
{{tasks.[task_name].result_state}} Görevinin [task_name]sonuç durumu. Olası değerler: success, failed, excluded, canceled, evicted, timedout, upstream_canceled, upstream_evicted ve upstream_failed.
{{tasks.[task_name].error_code}} Görevi [task_name] çalıştırırken bir hata oluştuysa görevin hata kodu. Olası değerlere örnek olarak RunExecutionError, ResourceNotFoundve UnauthorizedErrorverilebilir. Başarılı görevler için bu, boş bir dize olarak değerlendirilir.
{{tasks.[task_name].execution_count}} Görevin [task_name] kaç kez çalıştırıldığı (yeniden denemeler ve onarımlar dahil).
{{tasks.[task_name].notebook_path}} Not defteri görevinin [task_name]not defterinin yolu.
{{tasks.[task_name].values.[value_name]}} görevi tarafından ayarlanan anahtara [value_name] sahip görev [task_name]değeri.
{{workspace.id}} Çalışma alanına atanan benzersiz tanımlayıcı.
{{workspace.url}} Çalışma alanının URL'si.

İş oluştururken, işi düzenlerken veya Farklı parametrelerle bir işi çalıştırırken bu başvuruları herhangi bir görevle ayarlayabilirsiniz.

Ayrıca, görev değerleriyle bir işteki görevler arasında parametre geçirebilirsiniz. Bkz. Azure Databricks işinde görevler arasında bilgi paylaşma.

Tarih ve saat değerleri için seçenekler

Zaman tabanlı parametre değişkenlerinden dönüş değerini belirtmek için aşağıdaki bağımsız değişkenleri kullanın. Tüm dönüş değerleri UTC saat dilimindeki bir zaman damgasını temel alır.

Bağımsız değişken Açıklama
iso_weekday Zaman damgasının haftanın gününü temsil eden 1 ile 7 arasındaki bir rakam döndürür.
is_weekday Zaman damgası hafta içi bir gündeyse döndürür true .
iso_date Tarihi ISO biçiminde döndürür.
iso_datetime ISO biçiminde tarih ve saati döndürür.
year Zaman damgasının yıl bölümünü döndürür.
month Zaman damgasının ay bölümünü döndürür.
day Zaman damgasının gün bölümünü döndürür.
hour Zaman damgasının saat bölümünü döndürür.
minute Zaman damgasının dakika kısmını döndürür.
second Zaman damgasının ikinci bölümünü döndürür.
timestamp_ms Milisaniye cinsinden zaman damgasını döndürür.

Kullanım dışı bırakılan parametre değişkenleri

Aşağıdaki parametre değişkenleri kullanım dışıdır. Bunlar hala destekleniyor olsa da, mevcut işlerde yapılan tüm yeni işler veya güncelleştirmeler desteklenen değer başvurularını kullanmalıdır. Önerilen değiştirme başvurusu, her değişkenin açıklamasına eklenir.

Değişken Açıklama
{{job_id}} Bir işe atanan benzersiz tanımlayıcı. Bunun yerine job.id kullanın.
{{run_id}} Bir görev çalıştırmasına atanan benzersiz tanımlayıcı. Bunun yerine task.run_id kullanın.
{{start_date}} Bir görev çalıştırmasının başlatılı olduğu tarih. Biçimi UTC saat diliminde yy-MM-dd şeklindedir. Bunun yerine job.start_time.[argument] kullanın.
{{start_time}} Küme oluşturulduktan ve hazır olduktan sonra çalıştırmanın yürütme başlangıcının zaman damgası. BIÇIMI, tarafından System.currentTimeMillis()döndürülen UTC saat diliminde UNIX dönemlerinden bu yana milisaniyedir. Bunun yerine job.start_time.[format] kullanın.
{{task_retry_count}} İlk deneme başarısız olursa bir görevi çalıştırmaya çalışılmış olan yeniden deneme sayısı. İlk deneme için değer 0'dır ve her yeniden denemede artar. Bunun yerine task.execution_count kullanın.
{{parent_run_id}} Birden çok görev içeren bir işin çalıştırılmasına atanan benzersiz tanımlayıcı. Bunun yerine job.run_id kullanın.
{{task_key}} Birden çok görevi olan bir işin parçası olan göreve atanan benzersiz ad. Bunun yerine task.name kullanın.