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)[source]¶

基類： 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')[source]¶

mongo_conn_id = 'mongo_default'[source]¶

collection[source]¶

query[source]¶

mongo_db = None[source]¶

poke(context)[source]¶

派生此類時重寫。