# 注意，http request body是个json，这个json是个列表 ts=`date +%s`; curl -X POST -d "[{"metric": "test-metric", "endpoint": "test-endpoint", "timestamp": $ts,"step": 60,"value": 1,"counterType": "GAUGE","tags": "idc=lg,project=xx"}]" http://127.0.0.1:1988/v1/push

#!-*- coding:utf8 -*- import requests import time import json ts = int(time.time()) payload = [ { "endpoint": "test-endpoint", "metric": "test-metric", "timestamp": ts, "step": 60, "value": 1, "counterType": "GAUGE", "tags": "idc=lg,loc=beijing", }, { "endpoint": "test-endpoint", "metric": "test-metric2", "timestamp": ts, "step": 60, "value": 2, "counterType": "GAUGE", "tags": "idc=lg,loc=beijing", }, ] r = requests.post("http://127.0.0.1:1988/v1/push", data=json.dumps(payload)) print r.text

package main import ( "bytes" "encoding/json" "fmt" "io/ioutil" "net/http" ) func main() { apiurl := "http://127.0.0.1:1988/v1/push" type item struct { Endpoint string `json:"endpoint"` Metric string `json:"metric"` Timestamp int64 `json:"timestamp"` Step int `json:"step"` Value int64 `json:"value"` CounterType string `json:"counterType"` Tags string `json:"tags"` } type message struct { Item []item `json:"item"` } //json序列化 var post message post.Item = append(post.Item, item{Endpoint: "test-endpoint", Metric: "test-metric", Timestamp: 1500804940, Step: 60, Value: 10, CounterType: "GAUGE", Tags: "idc=xixian"}) jsonStr, _ := json.Marshal(post.Item) req, err := http.NewRequest("POST", apiurl, bytes.NewBuffer([]byte(jsonStr))) req.Header.Set("Content-Type", "application/json") client := &http.Client{} resp, err := client.Do(req) if err != nil { panic(err) } defer resp.Body.Close() }

show master status; show slave status; show global status; show global variables;

# 原来go包地址 cd /root/go/src/github.com/open-falcon/ git clone https://github.com/open-falcon/mymon.git cd mymon # 编译 [root@open-falcon-1 mymon]# make Run gofmt on all source files ... gofmt -l -s -w ... ==> Checking that build is using go version >= 1.10... go build -o mymon

[root@open-falcon-1 mymon]# pwd /root/go/src/github.com/open-falcon/mymon crontab -e # 写入如下 * * * * * cd /root/go/src/github.com/open-falcon/mymon && ./mymon -c etc/myMon.cfg

#!/bin/env python #-*- coding:utf-8 -*- import json import time import socket import os import re import sys import commands import urllib2, base64 class RedisStats: # 如果你是自己编译部署到redis，请将下面的值替换为你到redis-cli路径 _redis_cli = /usr/bin/redis-cli _stat_regex = re.compile(ur(w+):([0-9]+.?[0-9]*) ) def __init__(self, port=6379, passwd=None, host=127.0.0.1): self._cmd = %s -h %s -p %s info % (self._redis_cli, host, port) if passwd not in [, None]: self._cmd = %s -h %s -p %s -a %s info % (self._redis_cli, host, port, passwd) def stats(self): Return a dict containing redis stats info = commands.getoutput(self._cmd) return dict(self._stat_regex.findall(info)) def main(): ip = socket.gethostname() timestamp = int(time.time()) step = 60 # inst_list中保存了redis配置文件列表，程序将从这些配置中读取port和password，建议使用动态发现的方法获得，如： # inst_list = [ i for i in commands.getoutput("find /etc/ -name redis*.conf" ).split( ) ] insts_list = [ /etc/redis/redis.conf ] p = [] monit_keys = [ (connected_clients,GAUGE), (blocked_clients,GAUGE), (used_memory,GAUGE), (used_memory_rss,GAUGE), (mem_fragmentation_ratio,GAUGE), (total_commands_processed,COUNTER), (rejected_connections,COUNTER), (expired_keys,COUNTER), (evicted_keys,COUNTER), (keyspace_hits,COUNTER), (keyspace_misses,COUNTER), (keyspace_hit_ratio,GAUGE), ] for inst in insts_list: port = commands.getoutput("sed -n s/^port *([0-9]{4,5})/\1/p %s" % inst) passwd = commands.getoutput("sed -n s/^requirepass *([^ ]*)/\1/p %s" % inst) metric = "redis" endpoint = ip tags = port=%s % port try: conn = RedisStats(port, passwd) stats = conn.stats() except Exception,e: continue for key,vtype in monit_keys: #一些老版本的redis中info输出的信息很少，如果缺少一些我们需要采集的key就跳过 if key not in stats.keys(): continue #计算命中率 if key == keyspace_hit_ratio: try: value = float(stats[keyspace_hits])/(int(stats[keyspace_hits]) + int(stats[keyspace_misses])) except ZeroDivisionError: value = 0 #碎片率是浮点数 elif key == mem_fragmentation_ratio: value = float(stats[key]) else: #其他的都采集成counter，int try: value = int(stats[key]) except: continue i = { Metric: %s.%s % (metric, key), Endpoint: endpoint, Timestamp: timestamp, Step: step, Value: value, CounterType: vtype, TAGS: tags } p.append(i) print json.dumps(p, sort_keys=True,indent=4) method = "POST" handler = urllib2.HTTPHandler() opener = urllib2.build_opener(handler) url = http://127.0.0.1:1988/v1/push request = urllib2.Request(url, data=json.dumps(p) ) request.add_header("Content-Type",application/json) request.get_method = lambda: method try: connection = opener.open(request) except urllib2.HTTPError,e: connection = e # check. Substitute with appropriate HTTP code. if connection.code == 200: print connection.read() else: print {"err":1,"msg":"%s"} % connection if __name__ == __main__: proc = commands.getoutput( ps -ef|grep %s|grep -v grep|wc -l % os.path.basename(sys.argv[0])) sys.stdout.flush() if int(proc) < 5: main()