airflow.providers.snowflake.operators.snowpark¶

類¶

SnowparkOperator

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

基類: 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) – 一個布林值，指示是否在日誌中顯示返回值。預設為 True，允許輸出返回值日誌。可以設定為 False 以防止在返回大量資料（例如透過 XCom 向 TaskAPI 傳輸大量資料）時輸出返回值日誌。
warehouse (str | None) – 倉庫名稱（將覆蓋連線的 extra JSON 中定義的任何倉庫）
database (str | None) – 資料庫名稱（將覆蓋連線中定義的資料庫）
schema (str | None) – 模式名稱（將覆蓋連線中定義的模式）
role (str | None) – 角色名稱（將覆蓋連線的 extra JSON 中定義的任何角色）
authenticator (str | None) – Snowflake 的認證方式。'snowflake'（預設）使用 Snowflake 內部認證方式；'externalbrowser' 使用您的 Web 瀏覽器和 Okta、ADFS 或為您的帳戶定義的任何其他符合 SAML 2.0 的身份提供商 (IdP) 進行認證；'https://<your_okta_account_name>.okta.com' 透過原生 Okta 進行認證。
session_parameters (dict | None) – 連線 Snowflake 時，您可以設定會話級別引數

snowflake_conn_id = 'snowflake_default'[source]¶

warehouse = None[source]¶

database = None[source]¶

schema = None[source]¶

role = None[source]¶

authenticator = None[source]¶

session_parameters = None[source]¶

execute_callable()[source]¶

使用給定引數呼叫 Python 可呼叫物件。

返回:: 呼叫的返回值。