airflow.providers.papermill.operators.papermill¶

类¶

`NoteBook`	Jupyter notebook。
`PapermillOperator`	通过 papermill 执行带有参数注释的 jupyter notebook。

模块内容¶

class airflow.providers.papermill.operators.papermill.NoteBook[源码]¶

Bases: airflow.providers.common.compat.lineage.entities.File

Jupyter notebook。

template_fields: ClassVar[collections.abc.Collection[str]][源码]¶

type_hint: str | None = 'jupyter_notebook'[源码]¶

parameters: dict | None[源码]¶

meta_schema: str = 'airflow.providers.papermill.operators.papermill.NoteBook'[源码]¶

class airflow.providers.papermill.operators.papermill.PapermillOperator(*, input_nb=None, output_nb=None, parameters=None, kernel_name=None, language_name=None, kernel_conn_id=None, nbconvert=False, nbconvert_args=None, **kwargs)[源码]¶

Bases: airflow.models.BaseOperator

通过 papermill 执行带有参数注释的 jupyter notebook。

参数：

input_nb (str | NoteBook | None) – 输入 notebook，可以是路径或 NoteBook 入口。
output_nb (str | NoteBook | None) – 输出 notebook，可以是路径或 NoteBook 出口。
parameters (dict | None) – 要设置的 notebook 参数
kernel_name (str | None) – （可选）用于执行 notebook 的 kernel 名称（忽略 notebook 文档元数据中的 kernel 名称）

supports_lineage = True[源码]¶

template_fields: collections.abc.Sequence[str] = ('input_nb', 'output_nb', 'parameters', 'kernel_name', 'language_name', 'kernel_conn_id',...[源码]¶

parameters = None[源码]¶

input_nb = None[源码]¶

output_nb = None[源码]¶

kernel_name = None[源码]¶

language_name = None[源码]¶

kernel_conn_id = None[源码]¶

nbconvert = False[源码]¶

nbconvert_args = None[源码]¶

execute(context)[源码]¶

创建 operator 时派生。

Context 与渲染 jinja 模板时使用的字典相同。

有关更多 context，请参阅 get_template_context。

property hook: airflow.providers.papermill.hooks.kernel.KernelHook | None[源码]¶

获取有效的 hook。