Cadence go-client/client到达服务器以获取工作流导致恐慌

Question

Cadence首次用户：

场景我有一个cadence服务器在我的沙箱环境中运行。目的是获取工作流状态

我正在尝试使用这个cadence客户端

go.uber.org/cadence/client

在我的本地主机上与我的沙箱cadence服务器对话。

这是我的简单代码片段：

var cadClient client.Client

func main() {
wfID := "01ERMTDZHBYCH4GECHB3J692PC" << I got this from cadence-ui
ctx := context.Background()
wf := cadClientlient.GetWorkflow(ctx, wfID,"") <<< Panic hits here
log.Println("Workflow RunID: ",wf.GetID())
}

我肯定弄错了，因为客户端不知道如何访问节奏服务器。我参考了这个https://cadenceworkflow.io/docs/go-client/以找到正确的用法，但找不到任何参考（可能我错过了）。

任何关于如何解决/实施这个问题的帮助，都会有很大的帮助

Answer 1

我不知道你有多恐慌。根据代码片段，很可能您尚未初始化客户端。

要初始化它，请按照下面的示例代码操作：https://github.com/uber-common/cadence-samples/blob/master/cmd/samples/common/sample_helper.go#L82

和

https://github.com/uber-common/cadence-samples/blob/aac75c7ca03ec0c184d0f668c8cd0ea13d3a7aa4/cmd/samples/common/factory.go#L113

    ch, err := tchannel.NewChannelTransport(
        tchannel.ServiceName(_cadenceClientName))
    if err != nil {
        b.Logger.Fatal("Failed to create transport channel", zap.Error(err))
    }

    b.Logger.Debug("Creating RPC dispatcher outbound",
        zap.String("ServiceName", _cadenceFrontendService),
        zap.String("HostPort", b.hostPort))

    b.dispatcher = yarpc.NewDispatcher(yarpc.Config{
        Name: _cadenceClientName,
        Outbounds: yarpc.Outbounds{
            _cadenceFrontendService: {Unary: ch.NewSingleOutbound(b.hostPort)},
        },
    })

    if b.dispatcher != nil {
        if err := b.dispatcher.Start(); err != nil {
            b.Logger.Fatal("Failed to create outbound transport channel: %v", zap.Error(err))
        

    client := workflowserviceclient.New(b.dispatcher.ClientConfig(_cadenceFrontendService))