airflow.providers.snowflake.operators.snowpark¶
模組內容¶
類別¶
使用 Snowpark Python 程式碼執行 Python 函數。 |
- class airflow.providers.snowflake.operators.snowpark.SnowparkOperator(*, snowflake_conn_id='snowflake_default', python_callable, op_args=None, op_kwargs=None, templates_dict=None, templates_exts=None, show_return_value_in_logs=True, warehouse=None, database=None, schema=None, role=None, authenticator=None, session_parameters=None, **kwargs)[原始碼]¶
繼承自:
airflow.providers.common.compat.standard.operators.PythonOperator使用 Snowpark Python 程式碼執行 Python 函數。
另請參閱
有關如何使用此運算子的更多資訊，請查看指南： SnowparkOperator
- 參數
snowflake_conn_id (str) – 參考 Snowflake 連線 ID
python_callable (Callable) – 對可調用物件的參考
op_args (collections.abc.Collection[Any] | None) – 將在呼叫您的可調用物件時解包的位置引數列表
op_kwargs (collections.abc.Mapping[str, Any] | None) – 將在您的函數中解包的關鍵字引數字典
templates_dict (dict[str, Any] | None) – 一個字典，其中的值是範本，這些範本將在
__init__和execute之間由 Airflow 引擎進行範本化，並在套用範本後在您的可調用物件的上下文中可用。（已範本化）templates_exts (collections.abc.Sequence[str] | None) – 在處理範本化欄位時要解析的檔案副檔名列表，例如
['.sql', '.hql']show_return_value_in_logs (bool) – 一個布林值，指示是否顯示 return_value 日誌。預設為 True，允許 return value 日誌輸出。可以設定為 False 以防止在您傳回大量資料（例如傳輸大量 XCom 到 TaskAPI）時記錄 return value 輸出。
warehouse (str | None) – 倉庫名稱（將覆寫連線的額外 JSON 中定義的任何倉庫）
database (str | None) – 資料庫名稱（將覆寫連線中定義的資料庫）
schema (str | None) – 綱要名稱（將覆寫連線中定義的綱要）
role (str | None) – 角色名稱（將覆寫連線的額外 JSON 中定義的任何角色）
authenticator (str | None) – Snowflake 的驗證器。 ‘snowflake’（預設）使用內部 Snowflake 驗證器； ‘externalbrowser’ 使用您的網頁瀏覽器和 Okta、ADFS 或任何其他已為您的帳戶定義的 SAML 2.0 相容身分提供者 (IdP) 進行驗證； ‘https://<your_okta_account_name>.okta.com’ 透過原生 Okta 進行驗證。
session_parameters (dict | None) – 您可以在連線到 Snowflake 時設定會話層級參數