airflow.providers.fab.www.utils¶

属性¶

log

类¶

`UtcAwareFilterMixin`	用于 UTC 时间过滤的 Mixin。
`FilterIsNull`	判空过滤器。
`FilterIsNotNull`	判非空过滤器。
`FilterGreaterOrEqual`	大于或等于过滤器。
`FilterSmallerOrEqual`	小于或等于过滤器。
`UtcAwareFilterSmallerOrEqual`	用于 UTC 时间的小于或等于过滤器。
`UtcAwareFilterGreaterOrEqual`	用于 UTC 时间的大于或等于过滤器。
`UtcAwareFilterEqual`	用于 UTC 时间的相等过滤器。
`UtcAwareFilterGreater`	用于 UTC 时间的大于过滤器。
`UtcAwareFilterSmaller`	用于 UTC 时间的小于过滤器。
`UtcAwareFilterNotEqual`	用于 UTC 时间的不等于过滤器。
`AirflowFilterConverter`	获取 Airflow 特定过滤器的转换表。
`CustomSQLAInterface`	FAB 不知道如何处理带前导下划线的列，因为 WTForm 不支持它们。

函数¶

`get_session_lifetime_config`()	获取会话超时配置并优雅地处理过时的配置。
`get_fab_auth_manager`()
`get_fab_action_from_method_map`()	返回将方法与 FAB 操作关联的映射。
`get_method_from_fab_action_map`()	返回将 FAB 操作与方法关联的映射。

模块内容¶

airflow.providers.fab.www.utils.log[source]¶

airflow.providers.fab.www.utils.get_session_lifetime_config()[source]¶: 获取会话超时配置并优雅地处理过时的配置。

airflow.providers.fab.www.utils.get_fab_auth_manager()[source]¶

airflow.providers.fab.www.utils.get_fab_action_from_method_map()[source]¶: 返回将方法与 FAB 操作关联的映射。

airflow.providers.fab.www.utils.get_method_from_fab_action_map()[source]¶: 返回将 FAB 操作与方法关联的映射。

class airflow.providers.fab.www.utils.UtcAwareFilterMixin[source]¶

用于 UTC 时间过滤的 Mixin。

apply(query, value)[source]¶: 应用过滤器。

class airflow.providers.fab.www.utils.FilterIsNull(column_name, datamodel, is_related_view=False)[source]¶

基类：flask_appbuilder.models.filters.BaseFilter

判空过滤器。

name[source]¶

arg_name = 'emp'[source]¶: 表示过滤器的请求参数，子 Filter 类应设置此参数以启用 REST API 使用

apply(query, value)[source]¶: 覆盖此方法以实现您自己的新过滤器

class airflow.providers.fab.www.utils.FilterIsNotNull(column_name, datamodel, is_related_view=False)[source]¶

基类：flask_appbuilder.models.filters.BaseFilter

判非空过滤器。

name[source]¶

arg_name = 'nemp'[source]¶: 表示过滤器的请求参数，子 Filter 类应设置此参数以启用 REST API 使用

apply(query, value)[source]¶: 覆盖此方法以实现您自己的新过滤器

class airflow.providers.fab.www.utils.FilterGreaterOrEqual(column_name, datamodel, is_related_view=False)[source]¶

基类：flask_appbuilder.models.filters.BaseFilter

大于或等于过滤器。

name[source]¶

arg_name = 'gte'[source]¶: 表示过滤器的请求参数，子 Filter 类应设置此参数以启用 REST API 使用

apply(query, value)[source]¶: 覆盖此方法以实现您自己的新过滤器

class airflow.providers.fab.www.utils.FilterSmallerOrEqual(column_name, datamodel, is_related_view=False)[source]¶

基类：flask_appbuilder.models.filters.BaseFilter

小于或等于过滤器。

name[source]¶

arg_name = 'lte'[source]¶: 表示过滤器的请求参数，子 Filter 类应设置此参数以启用 REST API 使用

apply(query, value)[source]¶: 覆盖此方法以实现您自己的新过滤器

class airflow.providers.fab.www.utils.UtcAwareFilterSmallerOrEqual(column_name, datamodel, is_related_view=False)[source]¶

基类：UtcAwareFilterMixin, FilterSmallerOrEqual

用于 UTC 时间的小于或等于过滤器。

class airflow.providers.fab.www.utils.UtcAwareFilterGreaterOrEqual(column_name, datamodel, is_related_view=False)[source]¶

基类：UtcAwareFilterMixin, FilterGreaterOrEqual

用于 UTC 时间的大于或等于过滤器。

class airflow.providers.fab.www.utils.UtcAwareFilterEqual(column_name, datamodel, is_related_view=False)[source]¶

基类：UtcAwareFilterMixin, flask_appbuilder.models.sqla.filters.FilterEqual

用于 UTC 时间的相等过滤器。

class airflow.providers.fab.www.utils.UtcAwareFilterGreater(column_name, datamodel, is_related_view=False)[source]¶

基类：UtcAwareFilterMixin, flask_appbuilder.models.sqla.filters.FilterGreater

用于 UTC 时间的大于过滤器。

class airflow.providers.fab.www.utils.UtcAwareFilterSmaller(column_name, datamodel, is_related_view=False)[source]¶

基类：UtcAwareFilterMixin, flask_appbuilder.models.sqla.filters.FilterSmaller

用于 UTC 时间的小于过滤器。

class airflow.providers.fab.www.utils.UtcAwareFilterNotEqual(column_name, datamodel, is_related_view=False)[source]¶

基类：UtcAwareFilterMixin, flask_appbuilder.models.sqla.filters.FilterNotEqual

用于 UTC 时间的不等于过滤器。

class airflow.providers.fab.www.utils.AirflowFilterConverter(datamodel)[source]¶

基类：flask_appbuilder.models.sqla.filters.SQLAFilterConverter

获取 Airflow 特定过滤器的转换表。

conversion_table[source]¶

当实现您自己的过滤器时，您只需要定义新过滤器，并通过覆盖此属性来注册它们。这将把列类型映射到所有可能的过滤器。使用类似以下方式：

(
    ('is_text', [FilterCustomForText,
             FilterNotContains,
             FilterEqual,
             FilterNotEqual]),
    ('is_string', [FilterContains,
               FilterNotContains,
               FilterEqual,
               FilterNotEqual]),
    ('is_integer', [FilterEqual,
                FilterNotEqual]),
)

class airflow.providers.fab.www.utils.CustomSQLAInterface(obj, session=None)[source]¶

基类：flask_appbuilder.models.sqla.interface.SQLAInterface

FAB 不知道如何处理带前导下划线的列，因为 WTForm 不支持它们。

此 hack 将从用于查找列名的键中移除前导 '_'。

is_utcdatetime(col_name)[source]¶: 检查 datetime 是否为 UTC 时间。

is_extendedjson(col_name)[source]¶: 检查它是否为特殊的扩展 JSON 类型。

is_json(col_name)[source]¶: 检查它是否为 JSON 类型。

get_col_default(col_name)[source]¶

filter_converter_class[source]¶: 子类化时，使用您自己的自定义过滤器转换器覆盖