import requests def post_data(field, keys, value): db = 'news' influx_host = 'http://localhost:8086/write?db=%s' % db headers = {'Content-Type': 'application/octet-stream'} tmpkeys = ",".join(["%s=%s" % (k, v) for k, v in keys.items()]) if len(keys) > 0: data = "%s,%s %s" % (field, tmpkeys, value) else: data = "%s %s" % (field, value) print(data) try: ret = requests.post(influx_host, data=data, headers=headers) if ret.status_code // 100 != 2: print(ret.status_code) print(ret.text) print(data, "failed!!") except Exception as e: pass