python从mysql读取数据存入influxdb方便grafana展示
2018-05-13 13:27
465 查看
版权声明: https://blog.csdn.net/qq_26457433/article/details/80298619
#!/app/pluops/python/bin/python2.7
# -*- coding: UTF-8 -*-
import time
import urllib2
import urllib
import json
import sys
import MySQLdb
#from influxdb import InfluxDBClient
import json
db = MySQLdb.connect(host="",user="",passwd="",db="",port=3306,charset="utf8")
cursor = db.cursor()
data = cursor.execute("select * from (select StreamId,count(*) nub from XX where OpType=2 and Result=0 and CreateTime > date_sub(now(), interval 10 minute) GROUP BY XX) b where b.nub >=0 order by b.nub desc;")
info = cursor.fetchmany(data)
#print info
#print(info)
for stream,nub in info:
#print(stream,nub)
dbreqdata = "stream_id_num," + "streamid=" + str(stream) + " count=" + str(nub)
#print(dbreqdata)
dbrequrl = "http://influxdb:8086/write?db=stream_id_num"
user_agent = 'Mozilla/5.0'
headers = { 'User-Agent' : user_agent }
#print(dbreqdata)
#dbreq= urllib2.Request(url = dbrequrl,data =dbreqdata,headers=headers)
dbreq= urllib2.Request(url = dbrequrl,data =dbreqdata)
#print(dbreq)
urllib2.urlopen(dbreq)
阅读更多
# -*- coding: UTF-8 -*-
import time
import urllib2
import urllib
import json
import sys
import MySQLdb
#from influxdb import InfluxDBClient
import json
db = MySQLdb.connect(host="",user="",passwd="",db="",port=3306,charset="utf8")
cursor = db.cursor()
data = cursor.execute("select * from (select StreamId,count(*) nub from XX where OpType=2 and Result=0 and CreateTime > date_sub(now(), interval 10 minute) GROUP BY XX) b where b.nub >=0 order by b.nub desc;")
info = cursor.fetchmany(data)
#print info
#print(info)
for stream,nub in info:
#print(stream,nub)
dbreqdata = "stream_id_num," + "streamid=" + str(stream) + " count=" + str(nub)
#print(dbreqdata)
dbrequrl = "http://influxdb:8086/write?db=stream_id_num"
user_agent = 'Mozilla/5.0'
headers = { 'User-Agent' : user_agent }
#print(dbreqdata)
#dbreq= urllib2.Request(url = dbrequrl,data =dbreqdata,headers=headers)
dbreq= urllib2.Request(url = dbrequrl,data =dbreqdata)
#print(dbreq)
urllib2.urlopen(dbreq)
阅读更多
相关文章推荐
- python中,从mysql读取数据,并存入redis里面(2)
- python中,从mysql读取数据,并存入redis里面(3)
- Python3读取Excel数据存入MySQL的方法
- python中,从mysql读取数据,并存入redis里面(1)
- Python3读取Excel数据存入MySQL
- python采集mongodb数据写入influxdb展示grafana
- python读取mysql中数据保存至列表
- [置顶] python 读取excel数据到mysql
- Python抓取数据并存入到mysql
- Python3.6实现scrapy框架爬取数据并将数据插入MySQL与存入文档中
- RDD 直接存入MySQL,以及直接读取MySQL中数据
- Selenium(Python) ddt读取MySQL数据驱动
- Python3爬取网页数据存入MySQL
- 【jmeter】基于InfluxDB&Grafana的JMeter实时性能测试数据的监控和展示
- Python3 + Scrapy 爬取豆瓣评分数据存入Mysql与MongoDB数据库。
- Grafana 获取MySQL数据展示报表
- mysql读取显示和存入数据均乱码的解决
- 【Python】使用pandas库从MySQL中读取数据到excel中
- python将dateframe数据存入mysql
- Python使用web.py读取Mysql的数据