Jupyter Kernel 連線¶

Jupyter Kernel 連線型別支援遠端核心連線。

預設連線 ID¶

預設的 Jupyter Kernel 連線 ID 是 jupyter_kernel_default。

配置連線¶

host

遠端 Jupyter Kernel 的主機名/IP

Extra (可選)

指定可在核心連線中使用的額外引數（以 json 字典形式）。所有引數都是可選的。

session_key: 用於啟動與遠端核心連線的會話金鑰 [預設值: ‘’]。
shell_port: SHELL 埠 [預設值: 60316]。
iopub_port: IOPUB 埠 [預設值: 60317]。
stdin_port: STDIN 埠 [預設值: 60318]。
control_port: CONTROL 埠 [預設值: 60319]。
hb_port: HEARTBEAT 埠 [預設值: 60320]。

如果您透過 URI 配置連線，請確保 URI 的所有組成部分都經過 URL 編碼。

示例¶

將遠端核心連線設定為環境變數 (URI)

export AIRFLOW_CONN_JUPYTER_KERNEL_DEFAULT='{"host": "remote_host", "extra": {"session_key": "notebooks"}}'

建立 URI 連線的程式碼片段:

from airflow.models.connection import Connection

conn = Connection(
    conn_id="jupyter_kernel_default",
    conn_type="jupyter_kernel",
    host="remote_host",
    extra={
        # Specify extra parameters here
        "session_key": "notebooks",
    },
)

# Generate Environment Variable Name
env_key = f"AIRFLOW_CONN_{conn.conn_id.upper()}"

print(f"{env_key}='{conn.get_uri()}'")