helper.py 文件源码

def __init__(self, log, host, port, user, password, dbname, dbuser, dbpassword, dbMeasurement):
        assert (host is not None), "InfluxConnector: host value is None!"
        assert (port is not None), "InfluxConnector: port value is None!"
        assert (user is not None), "InfluxConnector: user name value is None!"
        assert (password is not None), "InfluxConnector: password value is None!"
        assert (dbname is not None), "InfluxConnector: dbname name value is None!"
        assert (dbuser is not None), "InfluxConnector: dbuser name value is None!"
        assert (dbpassword is not None), "InfluxConnector: dbpassword value is None!"
        assert (dbMeasurement is not None), "InfluxConnector: measurement value is None!"
        assert (len(dbMeasurement) > 0), "InfluxConnector: measurement value is empty!"

        self.host = host
        self.port = port
        self.user = user
        self.password = password
        self.dbname = dbname
        self.dbuser = dbuser
        self.dbpassword = dbpassword
        self.dbMeasurement = dbMeasurement
        self.log = log

        self.myInfluxDb = InfluxDBClient(self.host, self.port, self.user, self.password, self.dbname)
        self.myInfluxDb.create_database(self.dbname)    # repeated call possible, also the database exists
        self.myInfluxDb.switch_user(self.dbuser, self.dbpassword)