气流用户模拟(run_as_user)不工作

相关文章推荐

严肃的沙发 · 中国驻荷兰使馆举行招待会庆祝中国人民解放军建 ...· 8 月前 ·

逼格高的蛋挞 · 云南省市场监督管理局2023年广告监测情况分 ...· 10 月前 ·

孤独的领结 · 通勝列入非物質文化遺產！係不老百科全書？蔡真 ...· 11 月前 ·

活泼的树叶 · 厨娘笔记 —— 溏心鲍鱼 - 知乎· 1 年前 ·

逃跑的灭火器 · 校党委书记兰青、校长胡志斌带队赴新疆开展“医 ...· 1 年前 ·

腾讯云

开发者社区

文档意见反馈控制台

首页 TVP

文章/答案/技术大牛

发布

DAG Code:from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
current_time = datetime.now() - timedelta(days=1)
default_args = {
    'start_date': datetime.strptime(current_time.strftime('%Y-%m-%d %H:%M:%S'),'%Y-%m-%d %H:%M:%S'),
    'run_as_user': 'airflowaduser',
    'execution_timeout': timedelta(minutes=5)
dag = DAG('test_run-as_user', default_args=default_args,description='Run hive Query DAG', schedule_interval='0 * * * *',)
hive_ex = BashOperator(
    task_id='hive-ex',
    bash_command='whoami',
    dag=dag
)

*** Reading local file: /home/airflow/logs/test_run-as_user/hive-ex/2020-06-09T16:00:00+00:00/1.log
[2020-06-09 17:00:04,602] {taskinstance.py:620} INFO - Dependencies all met for <TaskInstance: test_run-as_user.hive-ex 2020-06-09T16:00:00+00:00 [queued]>
[2020-06-09 17:00:04,613] {taskinstance.py:620} INFO - Dependencies all met for <TaskInstance: test_run-as_user.hive-ex 2020-06-09T16:00:00+00:00 [queued]>
[2020-06-09 17:00:04,613] {taskinstance.py:838} INFO - 
--------------------------------------------------------------------------------
[2020-06-09 17:00:04,613] {taskinstance.py:839} INFO - Starting attempt 1 of 1
[2020-06-09 17:00:04,613] {taskinstance.py:840} INFO - 
--------------------------------------------------------------------------------
[2020-06-09 17:00:04,651] {taskinstance.py:859} INFO - Executing <Task(BashOperator): hive-ex> on 2020-06-09T16:00:00+00:00
[2020-06-09 17:00:04,651] {base_task_runner.py:133} INFO - Running: ['sudo', '-E', '-H', '-u', 'airflowaduser', 'airflow', 'run', 'test_run-as_user', 'hive-ex', '2020-06-09T16:00:00+00:00', '--job_id', '2314', '--pool', 'default_pool', '--raw', '-sd', 'DAGS_FOLDER/test_run-as_user/testscript.py', '--cfg_path', '/tmp/tmpbinlgw54']
[2020-06-09 17:00:04,664] {base_task_runner.py:115} INFO - Job 2314: Subtask hive-ex sudo: airflow: command not found
[2020-06-09 17:00:09,576] {logging_mixin.py:95} INFO - [[34m2020-06-09 17:00:09,575[0m] {[34mlocal_task_job.py:[0m105} INFO[0m - Task exited with return code 1[0m

RUN useradd -u [airflowaduser UID] -g 0 -d /home/airflow kettle && \
  # create airflowaduser

推荐文章

严肃的沙发 · 中国驻荷兰使馆举行招待会庆祝中国人民解放军建军96周年

8 月前

逼格高的蛋挞 · 云南省市场监督管理局2023年广告监测情况分析报告- 云南省市场监督管理局

10 月前

孤独的领结 · 通勝列入非物質文化遺產！係不老百科全書？蔡真步堂堪輿、曆法家學承傳四代！傳人蔡興華︰通勝很有生命力 - 有種生活 - 職場 - 生活 - etnet 經濟通 Mobile|香港新聞財經資訊和生活平台

11 月前

活泼的树叶 · 厨娘笔记 —— 溏心鲍鱼 - 知乎

1 年前

逃跑的灭火器 · 校党委书记兰青、校长胡志斌带队赴新疆开展“医教西行”专项行动

1 年前

气流用户模拟(run_as_user)不工作

1 个回答