如何定期检查容器是否在运行并定时调用函数？

一分耕耘，一分收获！既然打开了这篇文章《如何定期检查容器是否在运行并定时调用函数？》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

我正在使用 docker go sdk 来启动容器。这是我正在使用的代码：

    resp, err := cli.containercreate(ctx, &container.config{
        image: "logs2gist",
        cmd:   nil,
    }, nil, nil, nil, "")

    if err != nil {
        panic(err)
    }

    if err := cli.containerstart(ctx, resp.id, types.containerstartoptions{}); err != nil {
        panic(err)
    }

我还在文档中发现我们可以等待容器完成：

    statusCh, errCh := cli.ContainerWait(ctx, resp.ID, container.WaitConditionNotRunning)

    select {
    case err := <-errCh:
        if err != nil {
            panic(err)
        }
    case <-statusCh:
    }

    return resp.ID

我想知道在等待容器完成时是否有一种惯用的方法来运行函数。就我而言，我想每 x 分钟从容器中获取日志，并将其发送到外部 api。

处理这个问题的非惯用方法是：

1. 运行无限 for 循环。
2. 检查容器是否仍在运行；如果不打破循环
3. 如果正在运行，请获取日志并将其发布到 api。
4. 睡眠 x 分钟。

正确答案

将无限 for 循环与 select 语句结合使用是非常惯用的。

tick := time.newticker(10 * time.minute)
defer tick.stop()

statusch, errch := cli.containerwait(ctx, resp.id, container.waitconditionnotrunning)
for {
    select {
    case err := <-errch:
        // handle error & exit
        return
    case <-statusch: // not running?
        // get the last logs & exit...
        return
    case <-tick.c:
        // get the latest logs ...
    }
}

但是，如果您不喜欢这种方法，您可能需要考虑类似于 *sql.rows 提供对底层数据库数据的访问的方式。

type waiter struct {
    tick   *time.ticker
    chwait <-chan container.containerwaitokbody
    cherr  <-chan error
    wait   bool
    err    error
}

func (w *waiter) next() bool {
    if w.wait && w.err == nil {
        select {
        case err := <-w.cherr:
            w.err = err
            return true
        case <-w.chwait:
            w.wait = false
            return true
        case <-w.tick.c:
            return true
        }
    }
    return false
}

func (w *waiter) close() {
    w.tick.stop()
    // ... other cleanup if necessary ...
}

构造函数

func newwaiter(ctx context.context, containerid string, condition container.waitcondition, tickdur time.duration) *waiter {
    tick := time.newticker(tickdur)
    chwait, cherr := cli.containerwait(ctx, containerid, condition)
    return &waiter{
        tick:   tick,
        chwait: chwait,
        cherr:  cherr,
    }
}

你会像这样使用它：

w := newWaiter(ctx, resp.ID, container.WaitConditionNotRunning, 10*time.Minute)
defer w.close()

for w.next() {
    // grab logs
}
if w.err != nil {
    // handle error
}

以上就是《如何定期检查容器是否在运行并定时调用函数？》的详细内容，更多关于的资料请关注golang学习网公众号！