跳转到主要内容

为Apache Airflow回滚的Apache Beam提供程序包apache-airflow-backport-providers-apache-beam

项目描述

包apache-airflow-backport-providers-apache-beam

版本:2021.3.13

目录

回滚包

这是一个为apache.beam提供程序的回滚提供程序包。该提供程序包中所有类都位于airflow.providers.apache.beam Python包中。

仅支持 Python 3.6+ 版本用于此回滚软件包。

虽然 Airflow 1.10.* 仍然支持 Python 2.7+,但若想使用此回滚软件包,您需要将 Python 升级到 3.6+。

版本2021.3.13

错误修复

  • 改进 Apache Beam 操作符 - 重构操作符 - 公共 Dataflow 逻辑 (#14094)
  • 发布提供者 RC 之后,文档和工具中的修正 (#14082)
  • 从 BeamHook 中移除 WARNING (#14554)

安装

您可以通过以下命令在现有的 airflow 1.10.* 安装上安装此软件包:pip install apache-airflow-backport-providers-apache-beam

PIP需求

PIP 软件包 所需版本
apache-beam[gcp]

跨提供程序包依赖关系

这些是可能需要使用软件包所有功能的依赖项。您需要安装指定的回滚提供者软件包才能使用它们。

您可以在从 PyPI 安装时安装此类跨提供者依赖项。例如

pip install apache-airflow-backport-providers-apache-beam[google]
依赖软件包 额外
apache-airflow-backport-providers-google google

提供者类摘要

在 Airflow 2.0 中,所有 apache.beam 提供者的操作符、传输、钩子、传感器、机密都位于 airflow.providers.apache.beam 软件包中。您可以在 提供者软件包的命名约定 中了解更多信息。

操作符

新操作符

新 Airflow 2.0 操作符:airflow.providers.apache.beam 软件包
operators.beam.BeamRunJavaPipelineOperator
operators.beam.BeamRunPythonPipelineOperator

钩子

新钩子

新 Airflow 2.0 钩子:airflow.providers.apache.beam 软件包
hooks.beam.BeamHook

版本

版本2021.3.13

提交 已提交 主题
4e5763060 2021-03-03 从 BeamHook 中移除 WARNING (#14554)
589d6dec9 2021-02-27 准备发布下一波提供者:(#14487)
8a731f536 2021-02-05 改进 Apache Beam 操作符 - 重构操作符 - 公共 Dataflow 逻辑 (#14094)
10343ec29 2021-02-05 发布提供者 RC 之后,文档和工具中的修正 (#14082)

版本2021.2.5

提交 已提交 主题
d45739f7c 2021-02-04 发布 2 波提供者之后的发布流程修复 (#14059)
1872d8719 2021-02-03 添加 Apache Beam 操作符 (#12814)

项目详情


下载文件

下载适合您平台文件。如果您不确定选择哪个,请了解更多关于 安装软件包 的信息。

源分发

构建分发

支持者

AWS AWS 云计算和安全赞助商 Datadog Datadog 监控 Fastly Fastly CDN Google Google 下载分析 Microsoft Microsoft PSF 赞助商 Pingdom Pingdom 监控 Sentry Sentry 错误日志 StatusPage StatusPage 状态页面