我的守护进程中有以下SimpleHttpOperator： task_id='extracting_user'我使用的是气流2.3.0
浏览 13提问于2022-05-13得票数 0
回答已采纳
1回答
气流和谷歌床单
、、
我对气流和Python很陌生。我正在尝试将气流与Google连接起来，虽然与Python连接没有问题，但我不知道如何从气流中实现这一点。
浏览 1提问于2018-03-08得票数 0
回答已采纳
运行气流2.2.2with DAG(params={'api': 'my-api-id'}) as dag:
dag=dag)
其中my-api-id设置在气流
浏览 1提问于2022-09-01得票数 0
回答已采纳
我想上传二进制数据与REST使用气流的SimpleHttpOperator。upload_response = requests.put( )get_file = SFTPOperator(
task_idlo
浏览 3提问于2021-11-29得票数 0
回答已采纳
我试图发送参数到一个气流任务，以确定最后的执行。谢谢 task_id='XXX',
endpoint='/backend/XXX',
浏览 0提问于2019-09-11得票数 0
回答已采纳
嗨，我遇到了来自SimpleHttpOperator的奇怪行为。我像这样扩展了这个运算符： class EPOHttpOperator(SimpleHttpOperator): Operator for retrieving data from
浏览 44提问于2020-01-29得票数 1
1回答
气流数据处理
、、
新的气流，通过Udemy学习和阅读文档。一个任务或活动如何将其结果传递给下一个任务以进行后续处理？我意识到没有数据从一个任务流向另一个任务的概念，因为气流是真正的策划者。让我们以SimpleHttpOperator这样的例子为例，我在一个任务中使用它从web资源中获取一些数据，当SimpleHttpOperator内部似乎没有任何方法时，我如何才能将这些数据提供给下一个任务必须有某种“标准”的方法来放置由Simple
浏览 2提问于2021-07-18得票数 0
回答已采纳
我有一个使用SimpleHTTPOperator的气流任务，点击Google运行中的一个服务。我签了云运行日志，服务本身在12分钟内就完成了，但是气流任务一直在运行，我需要手动标记它才能成功。我对气流并不熟悉，所以我不知道我应该检查哪些日志，因为任务日志中没有有用的信息。
我使用LocalExecutor来运行DAG。
浏览 3提问于2022-03-17得票数 2
我理解，通过在xcom_push=True中设置SimpleHttpOperator，我可以从访问从Xcom返回的数据。但我不太清楚我是如何做到的。我想要做的是将Google的股价数据作为CSV数据读取，然后将它们插入到MySQL数据库中，以了解气流。一开始，我想我只需要使用两个操作符：但是现在我想我必须在中间添加PythonOperator？：
SimpleHttpOperator >> PythonOperator >
浏览 0提问于2018-02-25得票数 2
回答已采纳
from airflow.operators import SimpleHttpOperator, HttpSensor, , EmailOperator, S3KeySensor/usrlib/python3.6/dist-packages/airflow/utils/helpers.py:439: DeprecationWarning:直接从“airflow.operators”导入“SimpleHttpOperator对直接进口的支持将在气流2.0中完全取消。对
浏览 3提问于2020-03-10得票数 0
回答已采纳
我正在学习气流，我有一个简单的问题。DAG名为dog_retrieverfrom airflow import DAG}
schedule_interval='@once',
t1 = SimpleHttpOperator</
浏览 4提问于2017-10-10得票数 19
回答已采纳
我正试图正确地将data呈现在气流中的SimpleHttpOperator中，并通过dag_run发送配置 task_id="schema_detectordefault_args, schedule_interval="@once",) as dag:
result = SimpleHttpOperator
浏览 2提问于2021-05-12得票数 2
get_config_val',key='http_con_id') }}"from airflow.providers.http.operators.http import SimpleHttpOperatorget_config_val
浏览 2提问于2022-05-29得票数 0
回答已采纳
我试图使用气流获取API响应，并将它们保存到文件中以供进一步处理。气流在码头集装箱中，它需要代理和证书才能连接到网络。当直接使用来自码头的curl (通过代理和证书传递给它)时，它可以工作并显示结果，但是我不能在气流中用SimpleHTTPOperator复制这个结果。这就是我尝试过的； task_id="get_poke_stats", h
浏览 4提问于2019-11-29得票数 1
2回答
我有一个谷歌云功能，正在工作，我试图从一个气流DAG调用它。到目前为止，我尝试的是使用SimpleHttpOperator： task_id= "MY_TASK_NAME",
浏览 0提问于2019-08-27得票数 1
回答已采纳
我已经在GCC上创建了云作曲家(气流)，我已经设定了一个时间表，可以在世界协调时间05:00在28/10/22自动运行，但是到现在为止还没有运行。。
from
浏览 6提问于2022-10-28得票数 0
回答已采纳
我希望连接到一个外部API通过HTTPS与气流。我用url : myurl.com设置了我的主机，然后按照文档中的预期将模式值设置为'https‘。我不确定我的配置，但是当我尝试使用SimpleHttpOperator时
get_token = SimpleHttpOperator(任务_id=‘get_access_token’，方法=‘POST
浏览 10提问于2022-03-17得票数 3
我是第一次接触气流。我已经编写了一个使用SimpleHttpOperator提交HTTP Post的代码。在这种情况下，post请求返回一个令牌，我需要有关如何读取响应正文的帮助。get_templates = SimpleHttpOperator( method='POST',
endpoint='myendpoint
浏览 1提问于2019-05-07得票数 0
我从气流开始。我需要从我的PostgreSQL数据库中获得一个访问令牌，然后我必须使用该访问令牌使用SimpleHttpOperator函数查询API。这是我的密码：from airflow.providers.http.operators.http import SimpleHttpOperatortask_id='get_access_token', )
ge
浏览 6提问于2021-07-05得票数 3
回答已采纳
1回答
所以我的问题是:气流，因为它执行一个Python文件，该文件调用一个php脚本(Symfony)来执行一个创建的命令。命令本身工作正常。从气流中执行后者也非常有效(通过可视化显示气流:运行成功)。当我在symfony命令中引起错误时(退出(1)，抛出，…)，看看气流是如何反应的，它总是显示出成功。我怎么才能让他明白剧本不管用？description='one description', ta
浏览 12提问于2022-10-06得票数 0
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号