airflow.providers.arangodb.sensors.arangodb

类

AQLSensor

检查 ArangoDB 中是否存在与给定查询匹配的文档。

模块内容

class airflow.providers.arangodb.sensors.arangodb.AQLSensor(*, query, arangodb_conn_id='arangodb_default', **kwargs)[source]

基类: airflow.sensors.base.BaseSensorOperator

检查 ArangoDB 中是否存在与给定查询匹配的文档。

参数:

  • collection：目标 DB 集合。

  • query (str)：要探测的查询，或者你可以提供包含该查询的 .sql 文件

  • arangodb_conn_id (str)：连接 ArangoDB 时使用的 ArangoDB 连接 ID。

  • arangodb_db：目标 ArangoDB 名称。

template_fields: collections.abc.Sequence[str] = ('query',)[source]
template_ext: collections.abc.Sequence[str] = ('.sql',)[source]
template_fields_renderers[source]
arangodb_conn_id = 'arangodb_default'[source]
query[source]
poke(context)[source]

派生此类时重写。

此条目有帮助吗？