如何在 github actions 上将 aerospike 与 testcontainers 一起使用

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《如何在 github actions 上将 aerospike 与 testcontainers 一起使用》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

我正在尝试使用 github 操作在 testcontainers 上运行 aerospike，

当我在 github 操作上运行此操作时，我有时会收到错误，有时则不会，我收到的错误如下，

integration_test.go:124: error getting aerospike client: error creating cluster client: aero client failed to connect to [127.0.0.1]:32772 timeout:10s: resultcode: invalid_node_error, iteration: 0, indoubt: false, node: : failed to connect to hosts: [127.0.0.1:32772]

我的 aerospike 配置如下，

service {
    user root
    group root
    # number of nodes where the replica count is automatically reduced to 1.
    # paxos-single-replica-limit 1
    # pidfile /var/run/aerospike/asd.pid
    proto-fd-max 15000
    query-threads-limit 100
}

logging {
    # log file must be an absolute path.
    file ${logfile} {
        context any critical
    }

    # send log messages to stdout
    console {
        context any info
    }
}

network {
    service {
        address any
        port 3000

        # uncomment the following to set the `access-address` parameter to the
        # ip address of the docker host. this will the allow the server to correctly
        # publish the address which applications and other nodes in the cluster to
        # use when addressing this node.
        # access-address 
    }

    heartbeat {
        address any
        # mesh is used for environments that do not support multicast
        mode mesh
        port 3002

        # use asinfo -v 'tip:host=;port=3002' to inform cluster of
        # other mesh nodes

        interval 150
        timeout 10
    }

    fabric {
        address any
        port 3001 
    }
}

namespace persistent00 {
  replication-factor 1
  memory-size 20m
  storage-engine memory
  nsup-period 86400
}

这就是我通过使用测试容器进行连接的方式，

func startContainer(ctx context.Context) (*aerospikeContainer, error) {
    req := testcontainers.ContainerRequest{
        Image:        "aerospike/aerospike-server:6.2.0.12",
        ExposedPorts: []string{"3000/tcp", "3001/tcp", "3002/tcp"},
        Files: []testcontainers.ContainerFile{
            {
                HostFilePath:      "aerospike.conf",
                ContainerFilePath: "aerospike.conf",
            },
        },
        Cmd: []string{"--config-file", "aerospike.conf"},
        WaitingFor: wait.ForAll(
            wait.ForListeningPort("3000/tcp"),
            wait.ForLog("{persistent00} migrations: complete").WithOccurrence(2),
        ),
    }

    container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
        ContainerRequest: req,
        Started:          true,
    })
    if err != nil {
        return nil, err
    }

    return &aerospikeContainer{Container: container}, nil
}

我应该怎么做才能让它发挥作用？

我尝试使用心跳并增加了 withoccurence 但它似乎仍然不起作用

正确答案

此帖子建议在遇到 INVALID_NODE_ERROR: https://discuss.aerospike.com/t/invalid-node-error-code-3-after-some-writes/6037/9 时将客户端（在您的情况下为 Go 客户端）升级到最新版本

JDogMcSteezy 的评论是有道理的，如果它有时发生而不是总是发生（客户端在 Aerospike 可达之前尝试连接到 Aerospike），waitingFor 在这种情况下应该有所帮助。

我对 Go 不熟悉，但您可以在此处看到一个将 Aerospike 与 testcontainers 结合使用的稳定 Java 示例，该示例利用 Playtika 的公共库将 testcontainers 与 Aerospike 结合使用：https://github.com/aerospike/spring-data-aerospike

Playtika 的 testcontainers 依赖项：https://github.com/aerospike/spring-data-aerospike/blob/main/pom.xml#L256

这是测试容器的配置文件，默认只包含Aerospike的版本：https://github.com/aerospike/spring-data-aerospike/blob/main/src/test/resources/bootstrap.properties

这是测试中的配置类：https://github.com/aerospike/spring-data-aerospike/blob/main/src/test/java/org/springframework/data/aerospike/config/BlockingTestConfig.java#L30

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《如何在 github actions 上将 aerospike 与 testcontainers 一起使用》文章吧，也可关注golang学习网公众号了解相关技术文章。