İş ç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_arrival run_job_task , ve continuous table değ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 , ResourceNotFound ve UnauthorizedError verilebilir. 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. |
Geri Bildirim
https://aka.ms/ContentUserFeedback.
Çok yakında: 2024 boyunca, içerik için geri bildirim mekanizması olarak GitHub Sorunları’nı kullanımdan kaldıracak ve yeni bir geri bildirim sistemiyle değiştireceğiz. Daha fazla bilgi için bkz.Gönderin ve geri bildirimi görüntüleyin