0

我是 Prefect 的新手，想使用 Prefect 在 Azure Kubernetes 服务上部署 Kubernetes 作业。我已经建立了一个 Linux 容器，包括 Prefect、kubectl。我可以建立到 AKS 集群的连接，并且通过使用 kubectl，我可以在 AKS 上部署 Kubernetes 作业。但是它如何与 Prefect 一起工作？在容器中，我存储了 .py 文件和一个 YAML 文件，它定义了 Kubernetes 作业。

在此处输入图像描述

--> kubectl apply -f deploytestcontainer.yaml --> 有效

运行附加的示例 Prefect 代码也可以工作（但作业未在 AKS 中部署）

在此处输入图像描述

这就是“firstk8sjob.py”的内容

import prefect
from prefect import task, Flow
from prefect.run_configs import KubernetesRun
 
@task
def hello_task():
    flow.run_config = KubernetesRun(job_template_path="deploytestcontainer.yaml")
    logger = prefect.context.get("logger")
    logger.info("Hello world!")
 
with Flow("hello-flow") as flow:
    hello_task()
 
flow.run()

非常感谢您的建议！

4

1 回答 1

2

将流部署到 ​​Azure AKS 有两个步骤：

  1. 将您的 Kubernetes 代理部署到此集群
  2. 注册您的流程

首先，您需要部署一个 Kubernetes 代理。您可以使用以下命令生成清单文件：

prefect agent kubernetes install --rbac --key YOUR_API_KEY --label YOUR_LABEL > agent.yaml

然后您可以检查该文件，并根据需要对其进行修改（例如，更改图像版本以匹配您所需的 Python 和 Prefect 版本，在需要时添加环境变量等）。

请注意，API 密钥适用于 Prefect Cloud - 您是 Prefect Cloud 还是 Prefect Server 用户？如果您在 Prefect Server 上，则还需要那些 env variables。

清单准备就绪后，您可以将其应用到 AKS 群集：

kubectl apply -f agent.yaml # optionally set: -n yournamespace

然后，一旦代理运行，您只需在KubernetesRun.

请注意，您在不推荐的任务中设置运行配置，这可能是您的问题的原因。您应该将运行配置附加到您的流对象，如下所示：

import prefect
from prefect import task, Flow
from prefect.run_configs import KubernetesRun


@task
def hello_task():
    logger = prefect.context.get("logger")
    logger.info("Hello world!")


with Flow("hello-flow", run_config=KubernetesRun(labels=["YOUR_LABEL"])) as flow:
    hello_task()

if __name__ == "__main__":
    flow.register("YOUR_PROJECT_NAME")

您还可以在 CLI 中注册并摆脱此"__main__"块：

prefect register --project YOUR_PROJECT_NAME -p path/to/flow.py

注册流后，您可以使用以下命令触发 AKS 上的运行：

prefect run --name "hello-flow" --project YOUR_PROJECT_NAME --watch
于 2022-02-21T10:51:44.933 回答