odbtest/test/ctrl/cncc.go

package main

import (
	//"os"
	"fmt"
	//"time"
	"github.com/gomodule/redigo/redis"
	"github.com/vmihailenco/msgpack/v5"
	//"gitee.com/wecisecode/util/logger"
)

// dial wraps DialDefaultServer() with a more suitable function name for examples.
func dial() (redis.Conn, error) {
	c, err := redis.Dial("tcp", "47.92.151.165:11001")
	if err != nil {
		return nil, err
	}

	return c, nil
}

func main() {
	c, err := dial()
	if err != nil {
		fmt.Println(err)
		return
	}
	defer c.Close()

	params, _ := msgpack.Marshal([]interface{}{"test01"})
	option, _ := msgpack.Marshal(map[string]interface{}{"db": "matrix"})
	reply, err := c.Do("MQL", `select * from /matrix/devops/alert_status Where id = ?`, option, params)

	if err == nil {
		fmt.Printf("reply ==>%v \n", string(reply.([]byte)))
	} else {
		fmt.Printf("error ==>%v \n", err)
	}
}