airflow.providers.apache.hdfs.sensors.web_hdfs

模組內容

類別

WebHdfsSensor

等待檔案或資料夾在 HDFS 中出現。

MultipleFilesWebHdfsSensor

等待資料夾中的多個檔案在 HDFS 中出現。
class airflow.providers.apache.hdfs.sensors.web_hdfs.WebHdfsSensor(*, filepath, webhdfs_conn_id='webhdfs_default', **kwargs)[原始碼]

基於: airflow.sensors.base.BaseSensorOperator

等待檔案或資料夾在 HDFS 中出現。

template_fields: collections.abc.Sequence[str] = ('filepath',)[原始碼]
poke(context)[原始碼]

當衍生此類別時覆寫。

class airflow.providers.apache.hdfs.sensors.web_hdfs.MultipleFilesWebHdfsSensor(*, directory_path, expected_filenames, webhdfs_conn_id='webhdfs_default', **kwargs)[原始碼]

基於: airflow.sensors.base.BaseSensorOperator

等待資料夾中的多個檔案在 HDFS 中出現。

template_fields: collections.abc.Sequence[str] = ('directory_path', 'expected_filenames')[原始碼]
poke(context)[原始碼]

當衍生此類別時覆寫。

這個條目有幫助嗎？