我对Airflow完全不熟悉.我想在指定的日期运行一个简单的DAG.我很难在开始日期,执行日期和回填之间做出改变.运行DAG的命令是什么？
这是我以后尝试过的:
airflow run dag_1 task_1 2017-1-23
我第一次运行该命令时,任务执行正确,但是当我再次尝试时它没有用.
这是我跑的另一个命令:
airflow backfill dag_1 -s 2017-1-23 -e 2017-1-24
我不知道这个命令会发生什么.DAG每天会从23点到24点执行吗？
在运行上面的两个命令之前,我这样做了:
airflow initdb
airflow scheduler
airflow webserver -p 8085 --debug &
这是我的DAG
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2017, 1, 23, 12),
'email': ['airflow@airflow.com'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5),
}
dag = DAG(
'dag_1', default_args=default_args, schedule_interval=timedelta(1))
t1 = BashOperator(
task_id='create_clients',
bash_command='Rscript /scripts/Cli.r',
dag=dag)
t2 = …我很新闻,并试图自己建立一个博客,我遇到了SQLite操作错误的问题.我已经在Github和Stackoverflow上研究了类似的问题,但是在我发现的问题中没有出现典型的拼写错误或错误.如果有人能帮助我,那将是非常感激和非常好的,因为这个问题就像杀了我一样已经花了我两天,我觉得非常糟糕.
在代码中我已经定义了表名为"users_table"并在开头运行"db.create_all()"来创建表,但是每次提交时都会出现"没有这样的表user_table"的错误更新用户信息.
这是我测试SQLite操作的方法:
(under /project) python3 manage.py shell
>>> u = User(email='foo@bar.com', username='foobar', password='player')
>>> db.create_all()
>>> db.session.add(u)
>>> db.session.commit() # with following error message
Traceback (most recent call last):
File "C:\...\Python\Python36-32\lib\site-packages\sqlalchemy\engine\base.py", line 1182, in _execute_context
context)
File "C:\...\Python\Python36-32\lib\site-packages\sqlalchemy\engine\default.py", line 470, in do_execute
cursor.execute(statement, parameters)
sqlite3.OperationalError: no such table: users_table
...
...
sqlalchemy.exc.OperationalError: (sqlite3.OperationalError) no such table: users_table
我已将代码最小化为以下四个部分,这可能会重现错误消息:
/project/app/__init__.py:
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from config import config
db = SQLAlchemy()
def create_app(config_name):
app = Flask(__name__) …