`airflow.providers.mongo.sensors.mongo`¶

模块内容¶

类¶

MongoSensor

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

class airflow.providers.mongo.sensors.mongo.MongoSensor(*, collection, query, mongo_conn_id='mongo_default', mongo_db=None, **kwargs)[源代码]¶

基类：airflow.sensors.base.BaseSensorOperator

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

mongo_sensor = MongoSensor(
    collection="coll",
    query={"key": "value"},
    mongo_conn_id="mongo_default",
    mongo_db="admin",
    task_id="mongo_sensor",
)

参数

collection (str) – 目标 MongoDB 集合。
query (dict) – 用于查找目标文档的查询。
mongo_conn_id (str) – 连接到 MongoDB 时使用的 Mongo 连接 ID。
mongo_db – 目标 MongoDB 名称。

template_fields: collections.abc.Sequence[str] = ('collection', 'query')[源代码]¶

poke(context)[源代码]¶

派生此类时覆盖。

airflow.providers.mongo.sensors.mongo¶

模块内容¶

类¶

`airflow.providers.mongo.sensors.mongo`¶