influxdb_interface.py 文件源码

def _influxdb_writer_for(influxdb_client, measurement):
    mes_dict = {"measurement": measurement}
    def to_influxdf(*data_dicts):
        merged_dicts = merge(mes_dict, *data_dicts)
        logger.debug(merged_dicts)
        if influxdb_client.write_points([merged_dicts]):
            logger.debug("Success")
        else:
            logger.info("FAIL")
    return to_influxdf