send scs alarm data to InfluxDB

send_scs_to_influxdb.py

def send_to_influxdb(redis_id, redis_data):

	_data = [{
        "measurement": "scs.alarms",
        "tags": {
            "host": redis_data.get(b'hostname'),
            "app": redis_data.get(b'appname'),
	    "msgid": redis_data.get(b'msgid'),
        },
        "time": int(time.time()),
        "fields": {
            "condid": redis_data.get(b'condid'),
            "condname": redis_data.get(b'condname'),
            "conddesc": redis_data.get(b'conddesc'),
            "msgid": redis_data.get(b'msgid'),
            "msgtext": redis_data.get(b'msgtext'),
            "appid": redis_data.get(b'appid'),
            "appname": redis_data.get(b'appname'),
            "hostname": redis_data.get(b'hostname'),
            "ts": redis_data.get(b'epoch'),
	    "redisid": redis_id
        }
    }]
	
	dd("{'influx_data': %s}" % _data)

	bResult = influx.write_points(_data, time_precision='s')
	
	dd("send_to_influx", "DEBUG", status=bResult)