前言

InfluxDB是一个优秀的时序数据库，是最近几年物联网发展下业务需求下诞生的一款tsdb。据某云，某排行榜都有它的身影。
虽然他是go写的，我们就用python来实现下操作（因为我有个别的功能用python比较方便），操作非常简单。

大道至简越简单的越易维护

模块安装

pip install influxdb

使用

from influxdb import InfluxDBClient

class DbHelper:
    """docstring for DbHelper"""
    def __init__(self):
        self.client = InfluxDBClient('you influxdb server', 8086, 'your username', 'your password', 'your datebases') # 连接数据库

注意点

时区问题之写入
influxdb·默认采用utc时间为标准所以写入的时候如果显示指定时间需要转为utc时间

    current_time_utc = datetime.datetime.utcnow().isoformat("T")    
    w_json = [{
            "measurement": 'iot_data',
            "time": current_time_utc, #注意这里可以显式指定 也可以不写  如果写了就用utc时间
            "tags": {
                'senderid': '111111',
                'sensorid': '100000',
                'supplierid':'2020',
            },
            "fields": {
                'raw': jsonraw,
            }
        }]
    res=self.client.write_points(w_json)

对应关系数据库，measurement就是表，tags就是索引列，fields就是内容列。那他还有个牛掰的地方就是和mongodb一样，可以不预定义列。开发起来是不是很溜？

时区问题之查询

SELECT * FROM "iot_data" WHERE time >='2020-04-03 17:59:39'
SELECT * FROM "iot_data" WHERE time >='2020-04-03 17:59:39' tz('Asia/Shanghai')

这两个查询一个是把输入时间字符串当成utc时间来查询; 一个是当成我们东八区的、我们最熟悉的时间来查询。

influxdb之update
除了insert select delete ，这些和传统关系型数据库差不多。。
update也很简单用覆盖某个时间戳的insert就行。

insert xx_measurement名,longitude=120.33,latitude=23.33 temperature=22 154080088649461462

作者：小小吧主
链接：https://www.jianshu.com/p/7a634477bf59
来源：简书
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

ITPub博客

python操作InfluxDB附录InfluxDB注意坑集合

前言

模块安装

使用

注意点

最新文章