Dapr golang Docker Compose - 运行“errorCode”：“ERR_DIRECT_INVOKE”，“message”：“invoke API is not ready”错误

Question

我是第一次尝试 Dapr ....参考 https://github.com/dapr/go-sdk.. 的 Dapr go sdk。

...尝试在我的 Windows 10 机器上使用带有 Docker Compose 的 golang 托管 Dapr 服务 - 使用 VSCode - 并在连接到该服务时遇到问题。

我将 docker compose 文件设置为进行如下简单配置。并尝试使用 curl 通过 Dapr API 连接到服务

golang 服务（taskapi 服务）=> Dapr SideCar（taskapidapr）

我基于 https://github.com/dapr/go-sdk/blob/main/example/Makefile 的示例，但使用的是 Docker Compose。

当我尝试使用连接连接到服务时

curl -d "ping" -H "内容类型：text/plain;charset=UTF-8" "http://localhost:8300/v1.0/invoke/taskapi/method/echo"

我遇到了以下错误。

{"errorCode":"ERR_DIRECT_INVOKE","message":"调用 API 未准备好"}

Docker 中的 Dapr 日志显示“没有要刷新的 mDNS 应用程序”。 - 不知道这是否是它的原因以及如何处理它。

任何人都可以指出我所缺少的 - 非常感谢。

谢谢

• 阿萨杜

golang 包

package main

import (
    "context"
    "errors"
    "fmt"
    "log"
    "net/http"

    "github.com/dapr/go-sdk/service/common"
    daprd "github.com/dapr/go-sdk/service/http"
)

func main() {

    port := "8085"
    address := fmt.Sprintf(":%s", port)

    log.Printf("Creating New service at %v port", address)
    log.Println()

    // create a Dapr service (e.g. ":8080", "0.0.0.0:8080", "10.1.1.1:8080" )
    s := daprd.NewService(address)

    // add a service to service invocation handler
    if err := s.AddServiceInvocationHandler("/echo", echoHandler); err != nil {
        log.Fatalf("error adding invocation handler: %v", err)
    }

    if err := s.Start(); err != nil && err != http.ErrServerClosed {
        log.Fatalf("error listenning: %v", err)
    }
}

func echoHandler(ctx context.Context, in *common.InvocationEvent) (out *common.Content, err error) {
    if in == nil {
        err = errors.New("invocation parameter required")
        return
    }
    log.Printf(
        "echo - ContentType:%s, Verb:%s, QueryString:%s, %s",
        in.ContentType, in.Verb, in.QueryString, in.Data,
    )
    out = &common.Content{
        Data:        in.Data,
        ContentType: in.ContentType,
        DataTypeURL: in.DataTypeURL,
    }
    return
}

docker-compose.yml

version: "3"

services:
    taskapi:
        image: golang:1.16
        volumes:
            - ..:/go/src/lekha
        working_dir: /go/src/lekha/uploader
        command: go run main.go
        ports: 
            - "8085:8085"
        environment:
            aaa: 80
            my: I am THE variable value
        networks:
            - lekha
    taskapidapr:
        image: "daprio/daprd:edge"
        command: [
            "./daprd",
            "-app-id", "taskapi",
            "-app-protocol", "http",
            "-app-port", "8085",
            "-dapr-http-port", "8300",
            "-placement-host-address", "placement:50006",
            "-log-level", "debug",
            "-components-path", "/components"
        ]
        volumes:
            - "../dapr-components/:/components" # Mount our components folder for the dapr runtime to use
        depends_on:
            - taskapi
        ports: 
           - "8300:8300"
        networks:
           - lekha
        #network_mode: "service:taskapi" # Attach the task-api-dapr service to the task-api network namespace
    ############################
    # Dapr placement service
    ############################
    placement:
        image: "daprio/dapr"
        command: ["./placement", "-port", "50006"]
        ports:
            - "50006:50006"
        networks:
            - lekha
networks:
    lekha:
        

Daprd 在日志中显示这些 mDNS 消息 - 不确定这是否是原因

time="2021-05-24T01:06:13.6629303Z" level=debug msg="刷新所有 mDNS 地址。” app_id=taskapi 实例=442e04c9e8a6 scope=dapr.contrib type=log ver=edge

time="2021-05-24T01:06:13.6630421Z" level=debug msg="no mDNS apps to 刷新。” app_id=taskapi 实例=442e04c9e8a6 范围=dapr.contrib

此外，我看到预期端口上的容器...在 Docker 桌面上运行良好...

Answer 1

enter image description here

{
"errorCode": "ERR_DIRECT_INVOKE",
"message": "invoke API is not ready"

}

和你的一样