douyin/tool/prefect_cloud.py

import os
import consul_srv_client
ip,port = consul_srv_client.get_srv("prefect.service.consul")
prefect_api = f"http://{ip}:{port}/api"
# 在导入 prefect 之前设置环境变量
os.environ["PREFECT_API_URL"] = prefect_api

from prefect import flow

# 
@flow(log_prints=True)
def quickstart_flow(msg:str="none"):
    print(f"Hello, {msg}! Local quickstart flow is running! ")

if __name__ == "__main__":
    print(os.environ["PREFECT_API_URL"])
    # cli 触发： prefect deployment run -p msg="fuck you 123" 'quickstart-flow/my-quickstart-flow-local'
    # API 触发： 
    quickstart_flow.serve(
        name="my-quickstart-flow-local",
        tags=["testing", "tutorial"],
        description="Given a GitHub repository, logs repository statistics for that repo.",
        version="tutorial/deployments",)