我需要创建一个码头(1.13)容器,它将作为一个服务在码头群中运行,以调度作业(就像一个在需要时执行'docker‘的集群范围的crontab )。我是个系统管理员,并不是一个真正的程序员,所以我开始用bash,curl和jq来做。这是可行的,但肯定有改进的余地。
为了让您了解我正在处理的mumbo-jumpo,下面是我传递给码头套接字的几个调用片段,以了解服务在哪里运行:
# Get local docker node ID:
curl -s --unix-socket /var/run/docker.sock http:/v1.26/info | jq -r '.Name + " " + .Swarm.NodeID'
# List swarm node ID's:
curl -s --unix-socket /var/run/docker.sock http:/v1.26/nodes | jq -r '.[] | .Description.Hostname + " " + .ID'
# List swarm services:
curl -s --unix-socket /var/run/docker.sock http:/v1.26/nodes | jq -r '.[] | .Description.Hostname + " " + .ID'
# List running tasks:
curl -s --unix-socket /var/run/docker.sock http:/v1.26/tasks | jq -r '.[] | select( .Status.State | contains("running")) | .NodeID + " " + .ServiceID + " " + .ID + " " + .Status.State'我想用golang做得更好。
我理解在与tcp套接字对话时http.Get是如何工作的:
res, err := http.Get(url)
body, err := ioutil.ReadAll(res.Body)
err = json.Unmarshal(body, &p)
// p is then populated with the content of my request但是,我如何处理unix文件盒(/var/run/docker.sock)?我想我必须使用net.DialUnix,但到目前为止无法让它工作。
欢迎任何想法或建议。
发布于 2017-03-07 08:05:25
试试这个:
package main
import (
"fmt"
"net"
"log"
"bufio"
)
func main() {
conn, err := net.Dial("unix", "/var/run/docker.sock")
if err != nil {
panic(err)
}
fmt.Fprintf(conn, "GET /images/json HTTP/1.0\r\n\r\n")
status, err := bufio.NewReader(conn).ReadString('\t')
if err != nil {
log.Println(err)
}
fmt.Print("Message from server: "+status)
}另一种方法:
使用docker SDK,可用于python、go和其他一些语言。
https://stackoverflow.com/questions/42636989
复制相似问题