Cadence分别注册工作流程和活动

Question

我有一个由多台机器组成的网络，我正在使用cadence go客户端。

1号机需要登记活动

// Machine 1 registering activities
func sampleActivity(ctx context.Context) (string, error) {
    logger := activity.GetLogger(ctx)
    logger.Info("separate machines are handling this")
    return "Activity machine succeeded"
}
func main() {
     activity.RegisterWithOptions(sampleActivity, RegisterOptions{Name: "Machine1Activity"})
}

机器2需要注册工作流程。

// Machine 2 registering workflows
func sample_workflow(ctx workflow.Context, name string) (string, error) {
     ...
     err := workflow.ExecuteActivity(ctx, "Machine1Activity")
     ...
}

func main() {
    workflow.RegisterWithOptions(sampleWorkflow, "Machine2Workflow")
}

机器3需要启动以启动工作流。

// Machine 3 starting the workflow

// Prepare options and ctx

client.StartWorkflow(ctx, options, "Machine2Workflow", "Machine1Activity")

cadence前端服务在另一台机器上。

如何使用 go 客户端执行此操作？此外，收银机是否仅将工作流/活动保存在内存中？我怎样才能把它们推到节奏服务，以便其他机器也能找到它们。

Answer 1

目前，注册纯属特定员工本地注册。我们计划将来添加某种元数据服务，其中包含活动和工作流类型的目录。

要禁用机器1上的工作流工作器，请指定WorkerOptions.DisableWorkflowWorker。

若要禁用计算机 2 上的活动工作线程，请指定“工作线程选项”。

不需要在机器上注册任何东西3.