sql2slack对于slack 的处理是通过http 请求的，默认已经固定了格式了，以下是一个简单的修改，可以方便的支持钉钉webhook消息
而且具有通用性

需要修改部分

主要是关于使用resty 处理http 请求的部分，默认是写死的，可以修改为
job.go

 

    // _, err = resty.New().R().SetDoNotParseResponse(true).SetHeader("content-type", "application/json").SetBody(map[string]interface{}{

    //     "text": msg,

    // }).Post(j.Channel)

​

    // support dingding more flex

    _, err = resty.New().R().SetDoNotParseResponse(true).SetHeader("content-type", "application/json").SetBody(msg).Post(j.Channel)

    return err

job 配置定义

为了方便，我们可以基于关键字模式的钉钉webhook
example.s2s.hcl

 

job tst {

    channel = "替换为钉钉webhook的地址"

​

    driver = "mysql"

​

    dsn = "root:demo@tcp(mysql:3306)/demo"

​

    query = <<SQL

        SELECT users.* FROM users where status =1

    SQL

​

    schedule = "* * * * *"

​

    message = <<JS

        if ( $rows.length < 1 ) {

            return

        }

        log("this is a demo")

        var msg =  "";

         _.chain($rows).pluck('name').each(function(name){

            msg += name+"--------";

        })

         var info = {

            msgtype: "text",

            text: {

                content: msg

            }

        }

        log(JSON.stringify(info))

        say(JSON.stringify(info))

    JS

}

参考使用

• docker-compose 文件

version: "3"

services:

  mysql:

    image: mysql:5.7.16

    ports:

      - 3306:3306

    command: --character-set-server=utf8mb4 --collation-server=utf8mb4_unicode_ci

    environment:

      MYSQL_ROOT_PASSWORD: demo

      MYSQL_DATABASE: demo

      MYSQL_USER: demo

      MYSQL_PASSWORD: demo

      TZ: Asia/Shanghai

  sql2slack:

    build: ./

    image: dalongrong/sql2slack

    command: -jobs-dir /opt/hcls

    volumes:

      - "./hcls:/opt/hcls"

• dockerfile
  修改了官方的构建模式，基于源码构建

 

FROM golang:alpine as builder

WORKDIR /app

RUN  /bin/sed -i 's,http://dl-cdn.alpinelinux.org,https://mirrors.aliyun.com,g' /etc/apk/repositories

RUN apk add --no-cache git

COPY . /app/

ENV  GO111MODULE=on

ENV  GOPROXY=https://goproxy.cn

RUN go build

​

FROM alpine

COPY --from=builder /app/sql2slack ./

RUN echo $PWD

ENTRYPOINT ["./sql2slack"]

• 数据初始化

  需要先启动mysql 服务，然后执行下边的sql内容

CREATE TABLE `users` (

  `name` varchar(100) ,

  `status` varchar(100)

) ENGINE=InnoDB

​

INSERT INTO demo.users

(name, status)

VALUES('dalong', '0');

INSERT INTO demo.users

(name, status)

VALUES('demo', '1');

INSERT INTO demo.users

(name, status)

VALUES('rong', '1');

• 启动服务

docker-compose up -d  sql2slack

• 效果

 

 

说明

以上是一个简单的扩展调整来支持钉钉消息，因为sql2slack 支持多数据库以及多数据源（独立文件模式）
同时基于js 引擎的灵活数据处理能力，我们基于此可以做好多灵活的数据处理

参考资料

https://github.com/alash3al/sql2slack
https://github.com/rongfengliang/sql2webhook