Apache Airflow - 1.10 -如何在运行期间访问SQL文件
Apache Airflow是一个开源的工作流管理平台，可以帮助用户调度和监控各种数据处理任务。在Airflow中，可以通过创建DAG（有向无环图）来定义工作流，将各个任务按照依赖关系组织起来。
在运行期间，如果需要访问SQL文件，可以通过以下步骤实现：
- 首先，将SQL文件保存到Airflow的工作目录中，例如
/usr/local/airflow/sql。 - 在Airflow的DAG文件中，使用
PythonOperator来执行自定义的Python函数。在这个函数中，可以使用Python提供的文件操作函数来读取SQL文件的内容。 - 在Airflow的DAG文件中，使用
PythonOperator来执行自定义的Python函数。在这个函数中，可以使用Python提供的文件操作函数来读取SQL文件的内容。 - 在上述Python函数中，可以使用
psycopg2等库来连接数据库，并执行从SQL文件中读取的SQL语句。 - 在上述Python函数中，可以使用
psycopg2等库来连接数据库，并执行从SQL文件中读取的SQL语句。
请注意，上述代码示例中的数据库连接信息和文件路径仅供参考，您需要根据实际情况进行修改。
推荐的腾讯云相关产品：腾讯云数据库（TencentDB），提供了各种类型的数据库产品，包括关系型数据库、NoSQL数据库等。您可以根据需求选择适合的数据库产品，并将SQL文件中的语句在数据库中执行。
更多关于腾讯云数据库的信息，请参考：腾讯云数据库产品页
希望这些信息能帮助到您！
相关·内容
我对Apache Airflow非常陌生，有人能提供在windows环境(包括Docker)上安装和运行Apache Airflow Dev 2.0的步骤吗?我在那里找到了很多关于安装Apache Airflow 1.10.x的好文章。
浏览 22提问于2020-05-03得票数 0
2回答
气流安装不能
、、
我正在重新安装aiflow (在运行pip uninstall apache-airflow之后)
按照气流的快速启动指南，我运行：
export AIRFLOW_HOME=~/airflow
# install from pypi using pip
pip install apache-airflow
# initialize the database
airflow initdb
但是我看到了
bash: /usr/local/bin/airflow:没有这样的文件或目录
如何初始化气流数据库？
浏览 0提问于2019-08-28得票数 1
我正试图使用气流和它的操作员S3将大型文件从GCP传输到GCP。我已经能够传输400 Mb的文件，但是如果我尝试更大的: 2Gb，我会得到以下错误：
2018-09-19 12:30:43,907 {models.py:1736}错误- Errno 28设备回溯没有留下空间(最近一次调用)：
文件"/home/jma/airflow/env/lib/python3.5/site-packages/airflow/models.py"，第1633行，在_run_raw_task result = task_copy.execute(context=context)中
文件
浏览 2提问于2018-09-19得票数 0
我想在本地挂载远程目录的数据。
docker run -d -it --name redis \
--mount src=airflow-dags,target=/app/dags,type=volume,volume-driver=vieux/sshfs \
-p 6379:6379 \
redis
这是我的船坞-合成人。
version: '3'
x-airflow-common:
&airflow-common
image: ${AIRFLOW_IMAGE_NAME:-apache/airflow:2.3.3}
# build: .
env
浏览 19提问于2022-08-18得票数 0
最新版本的Airflow 1.10需要对记录仪进行一些设置。
我仔细地遵循，用airflow/config_templates/airflow_local_settings.py创建了一个config文件夹，并将其添加到PYTHONPATH。
不幸的是，在运行airflow时，我得到了这个错误：
ValueError: Unable to configure handler 'processor':
Cannot resolve 'airflow.utils.log.file_processor_handler.FileProcessorHandler':
浏览 0提问于2018-10-21得票数 3
我最近把气流从1.10.15升级到2.2.4。使用sudo安装。升级后升级DB。气流正在运行，但也有导入错误。
我有多个带有行from airflow.operators.mssql_operator import MsSqlOperator的DAG，但是一旦调度程序和and服务器启动，我将得到以下错误：
Broken DAG: [/opt/airflow/dags/admissions.py] Traceback (most recent call last):
File "/opt/airflow/dags/admissions.py", line 7, in <
浏览 16提问于2022-03-28得票数 0
回答已采纳
我正在尝试使用docker-compose的apache airflow，使用基本的容器容器apache/airflow:2.0.1。 我正在学习本教程https://airflow.apache.org/docs/apache-airflow/stable/start/docker.html# 如何运行简单的查询来从SQL Server数据库中获取数据？ 在这个阶段，我只想看看这是否可能。 我试着扩展图像 FROM apache/airflow:2.0.1
RUN pip install apache-airflow-providers-microsoft-azure==1.2.0rc1
浏览 13提问于2021-04-12得票数 0
回答已采纳
我试图通过气流中的OracleOperator调用一个包含多个语句的sql文件，但是它会给多个语句带来以下错误
例如，包含
调用DROP_OBJECTS('TABLE_XYZ')；
创建表TABLE_XYZ作为选择1虚拟从双；
2019-06-18 18:19:12,582 {init.py:1580}错误- ORA-00933: SQL命令未正确结束跟踪(最近一次调用)：文件"/usr/local/lib/python3.6/site-packages/airflow/models/init.py"，行1441，在_run_raw_task result =
浏览 1提问于2019-06-18得票数 1
1回答
使用：
sql_alchemy_conn = db+postgresql://username:xxx@127.0.0.1:5432/airflow给出错误：
sqlalchemy.exc.NoSuchModuleError:无法加载插件: sqlalchemy.dialects:db.postgresql
在使用时：
sql_alchemy_conn = postgresql+psycopg2://username:xxx@localhost:5432/airflow我可以运行airlfow webserver -p 8080，但是在运行调度程序：airflow scheduler时
浏览 2提问于2017-11-12得票数 13
回答已采纳
我在Ubuntu版本18.04.3服务器上实现了Apache-Airflow。当我设置它时，我使用的是sql lite通用数据库，而它使用的是顺序执行器。我这样做只是为了玩玩和适应这个系统。现在我正在尝试使用Local Executor，并且需要将我的数据库从sqlite转换到推荐的postgres sql。
有谁知道如何实现这一转变吗？我发现的所有教程都需要从一开始就使用postgres sql设置Airflow。我知道有一大堆可移动的部件，我害怕把我目前正在运行的东西搞乱。任何人谁知道如何做到这一点，或可以告诉我在哪里寻找非常感谢。谢谢!
浏览 2提问于2019-10-15得票数 9
我有一个docker-compose文件，如下所示： version: '3.8'
services:
scheduler:
image: apache/airflow
command: scheduler
restart: on-failure
env_file:
- .env
volumes:
- ./dags:/opt/airflow/dags
- ./logs:/opt/airflow/logs
web
浏览 17提问于2020-11-09得票数 2
回答已采纳
1回答
我需要连接到Postgres服务器实例，该实例是作为SystemD服务从docker-复合文件中运行的。
docker-compose containers ---> postgres as systemd
这是关于在localhost上设置外部Postgres的气流。
我以docker-compose为例，其中包括：
curl -LfO 'https://airflow.apache.org/docs/apache-airflow/2.2.3/docker-compose.yaml'
然而，在那里，他们正在定义一个Postgres容器，其中气流通过解析码头网络中的pos
浏览 14提问于2022-02-02得票数 0
回答已采纳
我必须完成一个共享气流1.10项目，因此我克隆了存储库，其结构如下：
airflow
├── airflow.cfg
├── airflow.db
├── dags
│ ├── dags_here.py
│
├── dags_conf
│ ├── some settings for dags
│ │ └── settings.py
│ │ ├── __init__.py
│ │ ├── settings.py
│ │ └── todo.txt
| |__ init.py
|
├── utilities
│ ├── __init__.p
浏览 6提问于2021-06-01得票数 1
回答已采纳
我目前在Airflow 1.10上使用Celery Executor。我的代理是AWS Elasticache Redis (5.0.6版)。如何启用在途加密？ 根据Airflow源代码，需要使用ssl_keyfile、ssl_certfile和ssl_ca_certs。 elif 'redis://' in broker_url:
broker_use_ssl = {'ssl_keyfile': conf.get('celery', 'SSL_KEY'),
'ssl_
浏览 21提问于2020-09-21得票数 3
我正在运行一个分布式气流2.4.0设置使用正式的码头形象。所有容器使用相同的.env文件和相同版本的气流图像。当我登录其中一个气流容器时，我会收到以下警告：
/home/airflow/.local/lib/python3.7/site-packages/airflow/configuration.py:545: DeprecationWarning: The sql_alchemy_conn option in [core] has been moved to the sql_alchemy_conn option in [database] - the old setting has be
浏览 16提问于2022-09-29得票数 1
回答已采纳
我已经开始使用KubernetesExecutor，并使用AWS设置了一个PV/PVC来为我的dags存储日志。我还使用s3远程日志记录。
在一个守护程序完成后，所有的日志记录都非常正常。但是，我希望能够看到我的作业的日志，因为它们正在运行很长时间。
当我执行到调度程序pod中时，当执行器pod正在运行时，由于共享的EFS，我能够看到当前正在运行的作业的.log文件。但是，当我cat日志文件时，只要执行器仍在运行，我就不会看到日志。但是，执行程序完成后，我可以在cat文件和气流UI中看到完整的日志。
奇怪的是，在运行过程中，当我执行到executor pod中，并且在共享EFS中执行完全相同的
浏览 3提问于2021-01-28得票数 1
我有一个正在运行的dag，我可以使用REST API停止它吗？ 有一种方法可以删除正在运行的dag：https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html#operation/delete_dag_run。 但是没有REST API如何停止一个正在运行的dag？ 谢谢!
浏览 145提问于2021-10-09得票数 1
回答已采纳
在apache气流配置中，我试图将顺序执行器更改为芹菜执行器，并在坞-组合文件中使用环境变量：
version: '3'
x-airflow-common:
&airflow-common
# In order to add custom dependencies or upgrade provider packages you can use your extended image.
# Comment the image line, place your Dockerfile in the directory where you placed the d
浏览 5提问于2021-11-22得票数 0
回答已采纳
1回答
为了学习，我一直试图在一组码头容器上设置一个气流实例。我只知道码头和气流的基本要素。
我一直在跟踪关于如何设置使用码头气流。
在遵循指南时，我可以启动容器，一切都如预期的那样工作。
我的下一步是开始在docker-come.yml-文件中更改不同的配置选项。我首先尝试设置不同的用户名和密码。
我在同一个目录中创建了一个..env文件，这个目录与docker-Compose.yml-文件相同。见下文。
AIRFLOW_UID=50000
USER='user'
PASSWORD='password'
DATABASE='airflow'
_AIRF
浏览 4提问于2022-11-12得票数 0
回答已采纳
TL;DR如何使dag中的任务可以访问资产(SQL文件、文本文件 大家好， 我正在运行单节点Airflow安装(1.10.12)。我有一个使用SQL语句的dag。出于可读性的考虑，我希望将这些语句保存在它们自己的SQL文件中。所以我的项目看起来是这样的： MyProject
- airflow_ftp_DAG.py
- airflow_ftp_assets (directory)
- WEX_HH_Upsert_SQL.sql 当我的dag运行时，它会抱怨找不到SQL文件。这是因为dag在不同的文件夹中运行它的任务(如运行os.getcwd()所示) 如何使我的S
浏览 7提问于2020-10-20得票数 1
回答已采纳
谁能告诉我如何在本地气流部署中配置kuberenetes执行器。我创建了一个名为airflow-cluster的集群，并创建了pod_template.yaml，并在airflow.cfg中进行了以下更改。
[kubernetes]
# Path to the YAML pod file that forms the basis for KubernetesExecutor workers.
pod_template_file = /home/caxe/airflow/logs/yamls/pod_template.yaml
worker_container_repository = apac
浏览 4提问于2022-01-21得票数 1
3回答
我是Python新手。我正在使用apache气流和一个任务，我称之为存储过程甲骨文。我看到错误非法的变量名/数字
t1 = OracleOperator(
task_id='Exe_PA',
oracle_conn_id='DEV_SR',
parameters=('1', 'TC', 'ESPA', '99', '2', '100', '28-08-2019', '0'),
sql= 'Begi
浏览 0提问于2019-08-29得票数 0
1回答
我目前正在使用docker-compose up来运行我从docker得到的apache airflow镜像。但是，当我尝试运行我的pythonOperator(包含其他库的python脚本)时，在构建airflow时出现错误。 我的docker-compose.yml： version: '3'
services:
postgres:
image: postgres:9.6
environment:
- POSTGRES_USER=airflow
- POSTGRES_PASSWORD=airflow
- POSTGR
浏览 10提问于2020-09-09得票数 2
回答已采纳
1回答
首先，我试图从1.9版本升级到1.10，所以我的设置包含两个vms，运行不同版本的气流，并进行不同的端口转发。我可以从运行于1.9的vm中访问UI，但不能从1.10访问UI。要调试，我想确认一下气流网络服务器是否正在运行。如果我执行
启动气流- sudo服务器
它不会抛出错误，但是当我查看netstat时，我没有看到任何进程侦听端口8080(默认)。
另外，我还没有创建任何用户，因为我不需要rbac身份验证？这会是个问题吗？
应@kaxil的要求。下面是ps aux | grep airflow的输出
有人能就如何解决这个问题提出一些建议吗？另外，如果您需要更多的资源，可以提供它。我
浏览 1提问于2018-12-20得票数 0
我需要从Composer中执行数据融合管道，为此使用Data：
from airflow.providers.google.cloud.operators.datafusion import (
CloudDataFusionCreateInstanceOperator,
CloudDataFusionCreatePipelineOperator,
CloudDataFusionDeleteInstanceOperator,
CloudDataFusionDeletePipelineOperator,
CloudDataFusionGetInstance
浏览 6提问于2021-10-15得票数 0
回答已采纳
1回答
我卸载了airflow 1.10.12，并使用python 3.6.9安装了airflow 2。当我在没有自定义DAG的情况下启动When服务器时，我收到警告： [2021-01-12 11:38:58,095] {dagbag.py:440} INFO - Filling up the DagBag from /dev/null
[2021-01-12 11:38:59,049] {providers_manager.py:283} WARNING - Exception when importing 'airflow.providers.google.cloud.hooks.da
浏览 85提问于2021-01-12得票数 2
2回答
我在码头使用气流和PostgreSQL。
因此，我在端口5433上建立了一个PostgreSQL数据库。集装箱(384 Ea7b6efb)。这是我有我的数据，我想拿我的dag在气流中。
码头工人ps
CONTAINER ID IMAGE COMMAND CREATED STATUS
PORTS NAMES
384eaa7b6efb postgres "docker-entrypoint.s…
浏览 2提问于2021-10-17得票数 1
回答已采纳
1回答
我是新来的气流公司，我正尝试在本地安装，按照下面链接上的说明：
我正在运行以下代码(如链接中提到的)：
# Airflow needs a home. `~/airflow` is the default, but you can put it
# somewhere else if you prefer (optional)
export AIRFLOW_HOME=~/airflow
# Install Airflow using the constraints file
AIRFLOW_VERSION=2.2.5
PYTHON_VERSION="$(python --versio
浏览 3提问于2022-04-27得票数 1
回答已采纳
我安装了气流。
airflow info产量：
Apache Airflow
version | 2.2.0
executor | SequentialExecutor
task_logging_handler | airflow.utils.log.file_task_handler.FileTaskHandler
sql_alchemy_conn |
浏览 5提问于2021-10-20得票数 0
回答已采纳
版本：
Terraform==.12
docker==19.03.8
python==3.8
postgreSQL==9.6
apache-气流=1.10.10
描述：
目标是为apache气流本地开发创建一个容器。我使用Postgres数据库作为后端存储气流的元数据，因为它需要使用气流LocalExecutor。最后，我使用Terraform创建气流和Postgres容器。
问题：
此错误在dev_airflow容器的entrypoint.sh中引发。具体来说，airflow initdb引发了与sql_alchemy_conn字符串相关的错误。sql_alchemy_conn字符串在运行a
浏览 7提问于2020-07-28得票数 0
我是商业智能的新手，我需要一些帮助我正在使用windows Jobscheduler来执行任务，但有时它会出错，所以我正在转移到apache airflow，我已经有一个执行的bat文件，但我想在apache airflow dags中使用它，这是我的文件bat代码
cd /d D:\EXMOOV\Scripts
调用RunDTS.bat EXMOOV Js_002_MOOV_AIR
我想把它放在一个dag文件代码中以便执行它，所以我拿了一个Dag代码的例子，试着把它放进去，使文件变得不可读，apache airflow无法读取它，这是我的尝试：
from datetime import ti
浏览 2提问于2020-03-26得票数 1
2回答
好吧，我可能很蠢，但无论如何，我如何通过的docker-compose文件安装额外的pip包？
我假设它们应该是一个标准的功能来获取一个requirements.txt或什么的。在检查它们的时，我确实看到了一些ENV变量，比如ADDITIONAL_PYTHON_DEPS，这些变量暗示着这是可能的，但是在docker文件中设置这些变量并不能实际安装库的。
version: '3'
x-airflow-common:
&airflow-common
image: ${AIRFLOW_IMAGE_NAME:-apache/airflow:2.0.1}
enviro
浏览 8提问于2021-03-18得票数 18
回答已采纳
Apache气流码头: sqlalchemy.exc.NoSuchModuleError:无法加载插件: sqlalchemy.dialects:mysqldb
version: '3'
x-airflow-common:
&airflow-common
image: ${AIRFLOW_IMAGE_NAME:-apache/airflow:2.3.3}
# build: .
environment:
&airflow-common-env
AIRFLOW__CORE__EXECUTOR: CeleryExecutor
A
浏览 8提问于2022-08-19得票数 1
回答已采纳
我正在尝试获得一个docker-compose文件，既可以处理气流也可以处理火花。Airflow通常在8080:8080上运行，这也是spark需要的。我有以下docker-compose文件： version: '3.7'
services:
master:
image: gettyimages/spark
command: bin/spark-class org.apache.spark.deploy.master.Master -h master
hostname: master
environment:
浏览 43提问于2020-10-23得票数 1
回答已采纳
我正在用Ansible安装气流，所以我有这样的命令
- pip
name: apache-airflow[s3, postgres]
version: 1.9.0
但是这个错误失败了：
安装"/usr/lib/python2.7/site-packages/pip/_internal/req/req_install.py"，apache-airflow 3==1.9.0 postgres==1.9.0 celery==1.9.0无效要求：'apache-airflow[s3==1.9.0‘回溯(最近一次调用)：文件第252行，在from_line req =r
浏览 0提问于2018-06-03得票数 1
回答已采纳
所以看起来我在Google引擎上安装的apache气流就坏了。一切都很顺利，两天前，所有DAG运行都出现在运行状态中。我正在使用LocalExecutioner。
当我试图查看日志时，会得到以下错误：
*日志文件不是本地的。*在这里获取： *无法从工作人员获取日志文件。
我哪儿都没碰过布景。我查看了所有的配置文件，扫描了日志，发现了这个错误。
2017年-12-16 20:08:42,558 {jobs.py:355} DagFileProcessor0错误-异常！传播。追溯(最近一次调用)：文件"/usr/local/lib/python3.4/dist-packages/airfl
浏览 5提问于2017-12-16得票数 1
我们使用的是Google Composer (一种管理的Airflow服务)和airflow v1.10和Python 3.6.8。为了部署我们的DAG，我们采用了封装的DAG ()方法。
从cmd行创建zip文件时，一切正常，如下所示
zip -r dag_under_test.zip test_dag.py
但是当我试图在最热的夹具上做这件事，所以我加载DagBag并测试我的DAG的完整性时，airflow根本不能识别这个压缩文件。下面是我的pytest fixture的代码
@fixture
def setup(config):
os.system("zip -r dag
浏览 5提问于2019-05-16得票数 0
在迁移到Airflow 2.0之前，我正在运行命令airflow upgrade_check进行检查。 我把Fernet问题理解为一个问题： Fernet is enabled by default
The fernet mechanism is enabled by default to increase the security of the default installation.
Problems:
1. fernet_key in airflow.cfg must be explicitly set empty as fernet mechanism is enable
浏览 24提问于2021-04-20得票数 0
1回答
在这里，我想从azure密钥库加载sql连接字符串。
version: '3'
x-airflow-common:
&airflow-common
image: ${AIRFLOW_IMAGE_NAME:-apache/airflow:2.2.4-python3.8}
# build: .
environment:
&airflow-common-env
AIRFLOW__CORE__EXECUTOR: CeleryExecutor
AIRFLOW__CORE
浏览 4提问于2022-03-23得票数 1
1回答
我们正在试验Apache Airflow ( 1.10rc2版本，python 2.7)，并将其部署到kubernetes、webserver和调度器到不同的pod，数据库也使用云sql，但我们一直面临调度器pod内存不足的问题。
在OOM的时刻，我们只运行了4个示例Dags (大约20个任务)。pod的内存是1Gib。我在其他帖子中看到，一个任务在运行时可能会消耗大约50Mib的内存，所有的任务操作都在内存中，没有任何东西被刷新到磁盘，所以已经有1 1Gb了。
有没有什么经验法则可以用来计算基于并行任务的调度器需要多少内存？
除了降低并行度之外，是否有任何调整可以用来减少调度器本身的内存使用
浏览 92提问于2018-08-28得票数 5
回答已采纳
我正在尝试使用Docker中的Apache airflow连接到我机器上的本地MS SQL服务器。我是个新手，找不到足够的文档来说明如何进行连接。 请建议使用docker中的Apache airflow连接到mssql服务器的所有可能方法。 提前谢谢。
浏览 19提问于2020-04-03得票数 0
我们使用apache-气流1.10.12作为我们目前的系统.我们需要从供应商的一些类别，在气流2。*。*。气流文档建议使用backport包在气流1.10中使用这些类。这将允许我们在不跳转到气流2的情况下测试新的类。但是当我在核心气流之后安装后端依赖项时，我会得到以下错误：“未能添加包，将pyproject.toml恢复到其原始内容”，在抛出一系列警告和错误之后。
你曾经面对过这个问题吗?你能解决这个问题吗？
为了重新创建这些步骤，下面是我所做的：
poetry init
poetry env use python3
poetry shell
poetry add apache
浏览 4提问于2021-07-25得票数 0
回答已采纳
1回答
我正在尝试定义一个气流策略，但我迷路了，而且也没有那么多文档。我在$HOME_AIRFLOW/config中创建了一个名为airflow_settings.py的文件。在里面，我有一个策略，它试图改变失败任务的队列。这项政策不起作用。谁能举个例子？ 顺便说一下，我使用的是airflow 1.10 谢谢
浏览 20提问于2019-02-27得票数 0
因此，在我的例子中，我以前在我的机器上直接运行过气流，现在我尝试使用码头在容器中运行，同时保持我以前的测试记录。不过，我一直有一些问题。
一点点背景..。当我第一次使用坞-撰写来打开我的容器时，气流正在发送一条错误消息，说明列dag_has_import_errors不存在。所以我继续创造了它，一切看起来都很好。
但是，现在我的工具都坏了，当我修改一个没有解决问题的代码时，我可以在when服务器顶部显示的简短错误信息中看到更新的代码行。
但是，当我解决这个问题时，代码不会改变，DAG仍然会中断。我会提供
\
另外，下面是我的坞-撰写文件(我注释掉了气流db init，但我是否应该将它与db升
浏览 13提问于2022-02-01得票数 1
回答已采纳
我正在尝试使用docker在我的windows机器上运行airflow。这是我从官方文档- https://airflow.apache.org/docs/apache-airflow/2.0.1/start/docker.html获得的链接。 我已经按照预期创建了目录结构，并下载了docker-compose yaml文件。按照文档的建议运行'docker-compose up airflow-init‘。我得到下面的错误 airflow-init_1 |
airflow-init_1 | [2021-07-03 10:19:29,721] {cli_act
浏览 89提问于2021-07-03得票数 0
我有一个包含1000多万条记录(行)的表。我正在尝试一次性加载到s3中，方法是选择*‘表，然后将其写入本地文件系统中的gzip文件。目前，我可以运行我的脚本将800,000条记录收集到gzip文件中，但随后我收到一个错误，其余的记录显然没有插入。
因为sql中没有延续(例如，如果您运行10个限制为800,000个查询，那么它将不会是有序的)。
那么，有没有办法编写一个可以批量加载10 million+表的python/airflow函数呢？也许在python中有一种方法，我可以执行一条select *语句，并在x条记录之后继续执行该语句到单独的gzip文件中？
下面是我的python/airf
浏览 2提问于2020-02-14得票数 0
我正在学习Apache气流，并尝试编写hello world版本的它。
我已经用python版本3.8和下面的包含dag和任务的代码安装了airflow版本2.0
import datetime
import logging
from airflow import DAG
from airflow.operators.python import PythonOperator
def greet_hello():
logging.info("Hello World")
dag = DAG("FirstDag", start_date=dateti
浏览 7提问于2021-02-07得票数 2
回答已采纳
我在本地mac上安装了气流2.0，支持PostgresSQL for sql_alchemy_conn。我的DAG运行良好+维护sqla数据库中的元数据，但是任何气流用户都会在未创建角色表/视图的情况下命令错误。
我尝试过设置和重置气流重置数据库，但是这些表在sql_alchemy_conn DB中仍然不可用。
psycopg2.ProgrammingError: relation "ab_permission_view_role" does not exist
LINE 2: FROM ab_permission_view_role JOIN ab_permission_vi
浏览 0提问于2019-01-11得票数 17
回答已采纳
1回答
我已经使用命令pip install airflow安装了Apache airflow。当我尝试通过键入airflow来访问airflow时，得到以下错误。
`Traceback (most recent call last):
File "/usr/bin/airflow", line 4, in <module>
from airflow import configuration
File "/usr/lib/python2.6/site-packages/airflow/__init__.py", line 29, in
浏览 3提问于2016-12-05得票数 3
2回答
我正在尝试安装一个名为Apache Airflow的程序。 这些说明说明了如何指定主文件夹 # airflow needs a home, ~/airflow is the default,
# but you can lay foundation somewhere else if you prefer
# (optional)
export AIRFLOW_HOME=~/airflow
# install from pypi using pip
pip install apache-airflow
# initialize the database
airflow initdb ht
浏览 20提问于2020-01-17得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
