insights/client/connection.py
def _legacy_upload_archive(self, data_collected, duration):
        '''
        Do an HTTPS upload of the archive
        '''
        file_name = os.path.basename(data_collected)
        try:
            from insights.contrib import magic
            m = magic.open(magic.MAGIC_MIME)
            m.load()
            mime_type = m.file(data_collected)
        except ImportError:
            magic = None
            logger.debug('python-magic not installed, using backup function...')
            from .utilities import magic_plan_b
            mime_type = magic_plan_b(data_collected)

        files = {
            'file': (file_name, open(data_collected, 'rb'), mime_type)}

        if self.config.analyze_container:
            logger.debug('Uploading container, image, mountpoint or tarfile.')
            upload_url = self.upload_url
        else:
            logger.debug('Uploading a host.')
            upload_url = self.upload_url + '/' + generate_machine_id()

        logger.debug("Uploading %s to %s", data_collected, upload_url)

        headers = {'x-rh-collection-time': str(duration)}
        net_logger.info("POST %s", upload_url)
        upload = self.session.post(upload_url, files=files, headers=headers)

        logger.debug("Upload status: %s %s %s",
                     upload.status_code, upload.reason, upload.text)
        if upload.status_code in (200, 201):
            the_json = json.loads(upload.text)
        else:
            logger.error("Upload archive failed with status code  %s", upload.status_code)
            return upload
        try:
            self.config.account_number = the_json["upload"]["account_number"]
        except:
            self.config.account_number = None
        logger.debug("Upload duration: %s", upload.elapsed)
        return upload

        Do an HTTPS upload of the archive
        
Do an HTTPS upload of the archive
Do an HTTPS upload of the archive
def _legacy_upload_archive(self, data_collected, duration):
        file_name = os.path.basename(data_collected)
        try:
            from insights.contrib import magic
            m = magic.open(magic.MAGIC_MIME)
            m.load()
            mime_type = m.file(data_collected)
        except ImportError:
            magic = None
            logger.debug('python-magic not installed, using backup function...')
            from .utilities import magic_plan_b
            mime_type = magic_plan_b(data_collected)
        files = {
            'file': (file_name, open(data_collected, 'rb'), mime_type)}
        if self.config.analyze_container:
            logger.debug('Uploading container, image, mountpoint or tarfile.')
            upload_url = self.upload_url
        else:
            logger.debug('Uploading a host.')
            upload_url = self.upload_url + '/' + generate_machine_id()
        logger.debug("Uploading %s to %s", data_collected, upload_url)
        headers = {'x-rh-collection-time': str(duration)}
        net_logger.info("POST %s", upload_url)
        upload = self.session.post(upload_url, files=files, headers=headers)
        logger.debug("Upload status: %s %s %s",
                     upload.status_code, upload.reason, upload.text)
        if upload.status_code in (200, 201):
            the_json = json.loads(upload.text)
        else:
            logger.error("Upload archive failed with status code  %s", upload.status_code)
            return upload
        try:
            self.config.account_number = the_json["upload"]["account_number"]
        except:
            self.config.account_number = None
        logger.debug("Upload duration: %s", upload.elapsed)
        return upload
def _legacy_upload_archive ( self , data_collected , duration ) : file_name = os . path . basename ( data_collected ) try : from insights . contrib import magic m = magic . open ( magic . MAGIC_MIME ) m . load ( ) mime_type = m . file ( data_collected ) except ImportError : magic = None logger . debug ( 'python-magic not installed, using backup function...' ) from . utilities import magic_plan_b mime_type = magic_plan_b ( data_collected ) files = { 'file' : ( file_name , open ( data_collected , 'rb' ) , mime_type ) } if self . config . analyze_container : logger . debug ( 'Uploading container, image, mountpoint or tarfile.' ) upload_url = self . upload_url else : logger . debug ( 'Uploading a host.' ) upload_url = self . upload_url + '/' + generate_machine_id ( ) logger . debug ( "Uploading %s to %s" , data_collected , upload_url ) headers = { 'x-rh-collection-time' : str ( duration ) } net_logger . info ( "POST %s" , upload_url ) upload = self . session . post ( upload_url , files = files , headers = headers ) logger . debug ( "Upload status: %s %s %s" , upload . status_code , upload . reason , upload . text ) if upload . status_code in ( 200 , 201 ) : the_json = json . loads ( upload . text ) else : logger . error ( "Upload archive failed with status code  %s" , upload . status_code ) return upload try : self . config . account_number = the_json [ "upload" ] [ "account_number" ] except : self . config . account_number = None logger . debug ( "Upload duration: %s" , upload . elapsed ) return upload
Do an HTTPS upload of the archive
Do an HTTPS upload of the archive
'''
        Do an HTTPS upload of the archive
        '''
self
data_collected
duration