__main__.py 文件源码

def init(self, args):
        self._client = InfluxDBClient(
                args.influx_host,
                args.influx_port,
                args.username,
                args.password,
                args.db_name)

        # Create database if it doesn't exist
        dbs = self._client.get_list_database()
        if not any(db['name'] == args.db_name for db in dbs):
            self._client.create_database(args.db_name)

        self.session = args.session
        self.run_no = args.run_no
        self._device_values = {}
        self._update_list = {}
        self._last_resend_time = None

        resend_thread = Thread(target=self._resend_thread)
        resend_thread.daemon = True
        resend_thread.start()