Jupyter 内核连接¶

Jupyter 内核连接类型启用远程内核连接。

默认连接 ID¶

默认 Jupyter 内核连接 ID 为 jupyter_kernel_default。

配置连接¶

主机

远程 Jupyter 内核的 HOSTNAME/IP

额外（可选）

指定可在内核连接中使用的额外参数（作为 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()}'")