Hava akımı: Günlük dosyası yerel değil, Desteksiz uzaktan günlüğü konumu

Ben Hava akımı arayüzünden görevlere bağlı günlükleri görebilmek mümkün değilim: airflow.cfg dosyasında Hava akımı: Günlük dosyası yerel değil, Desteksiz uzaktan günlüğü konumu

Günlüğü ilgili ayarlar şunlardır:

remote_base_log_folder =
base_log_folder = /home/my_projects/ksaprice_project/airflow/logs
worker_log_server_port = 8793
child_process_log_directory = /home/my_projects/ksaprice_project/airflow/logs/scheduler

remote_base_log_folter ayarlamam rağmen, günlüğü http://:8793/log/tutorial/print_date/2017-08-02T00:00:00'dan almaya çalışıyor - bu davranışı anlamıyorum. Ayarlara göre, işçiler günlükleri /home/my_projects/ksaprice_project/airflow/logs'da saklamalı ve uzak konum yerine aynı yerden getirilmelidir.

Güncelleme task_instance tablosu içeriği:

kaynak

2017-08-03 javed

Hava akışını hangi modda çalıştırıyorsunuz - Yerel, Kereviz ? CeleryExecutor –

adresindeki konuyla ilgili ayrıntılı bir tartışma olduğu için aşağıdaki URL'yi kontrol etmeyi deneyin: DB yapılandırılmış - tablo - task_instance öğesini kontrol edebilirsiniz. Bu tabloda, günlük URL'sinin oluşturulduğu ve kaynaklandığı yerden 'ana makine adı' adlı bir sütun var. İdeal olarak bu değer, çalışan düğümünüzde 'hostname' komutunu çalıştırdığınızla aynıdır. – javed

'u kullanarak https://github.com/puckel/docker-airflow/issues/44 –

Bunu da ben koştum ve görevleri unpause vardı.

dags_are_paused_at_creation = False

Ben de aynı sorunla karşı karşıya

dags_are_paused_at_creation = False

kaynak

2017-09-29 17:48:01 user8697151

benim airflow.cfg içinde duraklatılmayan varsayılan olarak yeni DAG'leri ayarlayın.

airflow.cfg değişkeninin altındaki değişkenlerin ayarlanması benim için çalıştı. Makinenin localhost yerine FQDN {hostname} olarak {hostname} kullanın.

endpoint_url = http://{hostname}:8080 

base_url = http://{hostname}:8080

Şansın en iyisi!

kaynak

2017-11-04 19:33:59 Jaguar

base_url kesinlikle önemlidir, UI'deki sayfaların çoğu dinamik olarak bağlantılar oluşturmak için kullanır. Endpoint_url sadece cli tarafından kullanılıyor gibi görünüyor, bu yüzden bu konuda yardımcı olduğundan şüpheliyim. – Davos

https://github.com/apache/incubator-airflow/blob/master/airflow/models.py#L984 Örneğin, günlük dosyası yolunun üretildiği ve base_url yapılandırma değerini kullanan aşağıdaki yöntem log_url. – Davos

bu kadar ilk emin olun, Sen UI bakıyorsun görüntü 1 orada bir zaman damgası, sen isim olarak bu zaman damgası ile klasör/dosya var Günlüklerinize emin olmaktır ..

görebileceğiniz gibi Eğer, benim durumumda benim günlük klasörü size DAG gidin ve GRAFİK-VIEW seçtiğinizde Yani benim günlük URL

http://localhost:8080/admin/airflow/log?task_id=my_sensor_task&dag_id=my_test_dag&execution_date=2017-11-14T08:36:06.920727

olduğunu

(AIRFLOW-ENV) [[email protected] dags]$ ll /home/cloudera/workspace/python/airflow_home/logs/my_test_dag/my_sensor_task 
total 8 
-rw-rw-rw- 1 cloudera cloudera 3215 Nov 14 08:45 2017-11-12T12:00:00 
-rw-rw-rw- 1 cloudera cloudera 2694 Nov 14 08:45 2017-11-14T08:36:06.920727 
(AIRFLOW-ENV) [[email protected] dags]$

benziyor, dizinde oluşturulan günlük dosyaları var sen c "RUN" un yanındaki bir aşağıya bakın, uygun koşuyu seçin ve sonra aşağıdaki grafik görünümünde uygun görev/operatörü seçin ve görünüm-günlüğü seçin

kaynak

2017-11-14 17:46:06 Manjesh

Hava akımı: Günlük dosyası yerel değil, Desteksiz uzaktan günlüğü konumu

cevap

İlgili konular