Hello World快速开始

要使用 Agently Workflow 的能力非常简单,您只需要使用Agently.Workflow()方法创建一个workflow对象即可以开始使用。

下面的代码样例将帮助您快速了解 Agently Workflow 编写的关键步骤,并创建您的第一个工作流案例:

我的第一个workflow
import Agently

# 创建工作流对象
workflow = Agently.Workflow()

# 定义工作块
@workflow.chunk()
def user_input(inputs, storage):
    # 参数inputs承接上游直接传递的数据
    # 参数storage管理单个工作流内共享的数据
    storage.set("init_inputs", inputs["default"])
    new_msg = input("[输入新的信息]: ")
    return new_msg

@workflow.chunk()
def echo(inputs, storage):
    print("[您刚才输入的是]: ", inputs["default"])
    return {
        "user_input": inputs["default"],
        "init_inputs": storage.get("init_inputs"),
        "init_storage": storage.get("init_storage")
    }

# 定义工作流运行关系
(
    workflow
        .connect_to("user_input")
        .connect_to("echo")
        .connect_to("END") # 连接到系统内置的end块
)

# 启动工作流并获取运行结果
result = workflow.start(
    # 默认参数的值可传递给第一步连接块的inputs
    "Hello Agently", 
    # 可选参数storage可设置storage的初始值
    storage={ "init_storage": "Hello Agently Workflow" }
)
print(result) # 工作流运行结果是连接到END块的数据
输出结果
[输入新的信息]: Hello World
[您刚才输入的是]:  Hello World
{'default': {
    'user_input': 'Hello World',
    'init_inputs': 'Hello Agently',
    'init_storage': 'Hello Agently Workflow'
} }