yandextank/plugins/DataUploader/client.py
def __make_writer_request(
            self,
            params=None,
            json=None,
            http_method="POST",
            trace=False):
        '''
        Send request to writer service.
        '''
        request = requests.Request(
            http_method,
            self.writer_url,
            params=params,
            json=json,
            headers={
                'User-Agent': self.user_agent})
        ids = id_gen(str(uuid.uuid4()))
        network_timeouts = self.network_timeouts()
        maintenance_timeouts = self.maintenance_timeouts()
        while True:
            try:
                response = self.__send_single_request(request, ids.next(), trace=trace)
                return response
            except (Timeout, ConnectionError, ProtocolError):
                logger.warn(traceback.format_exc())
                try:
                    timeout = next(network_timeouts)
                    logger.warn(
                        "Network error, will retry in %ss..." %
                        timeout)
                    time.sleep(timeout)
                    continue
                except StopIteration:
                    raise self.NetworkError()
            except self.UnderMaintenance as e:
                try:
                    timeout = next(maintenance_timeouts)
                    logger.warn(
                        "Writer is under maintenance, will retry in %ss..." %
                        timeout)
                    time.sleep(timeout)
                    continue
                except StopIteration:
                    raise e
def __make_writer_request(
            self,
            params=None,
            json=None,
            http_method="POST",
            trace=False):
        '''
        Send request to writer service.
        '''
        request = requests.Request(
            http_method,
            self.writer_url,
            params=params,
            json=json,
            headers={
                'User-Agent': self.user_agent})
        ids = id_gen(str(uuid.uuid4()))
        network_timeouts = self.network_timeouts()
        maintenance_timeouts = self.maintenance_timeouts()
        while True:
            try:
                response = self.__send_single_request(request, ids.next(), trace=trace)
                return response
            except (Timeout, ConnectionError, ProtocolError):
                logger.warn(traceback.format_exc())
                try:
                    timeout = next(network_timeouts)
                    logger.warn(
                        "Network error, will retry in %ss..." %
                        timeout)
                    time.sleep(timeout)
                    continue
                except StopIteration:
                    raise self.NetworkError()
            except self.UnderMaintenance as e:
                try:
                    timeout = next(maintenance_timeouts)
                    logger.warn(
                        "Writer is under maintenance, will retry in %ss..." %
                        timeout)
                    time.sleep(timeout)
                    continue
                except StopIteration:
                    raise e
def __make_writer_request ( self , params = None , json = None , http_method = "POST" , trace = False ) : request = requests . Request ( http_method , self . writer_url , params = params , json = json , headers = { 'User-Agent' : self . user_agent } ) ids = id_gen ( str ( uuid . uuid4 ( ) ) ) network_timeouts = self . network_timeouts ( ) maintenance_timeouts = self . maintenance_timeouts ( ) while True : try : response = self . __send_single_request ( request , ids . next ( ) , trace = trace ) return response except ( Timeout , ConnectionError , ProtocolError ) : logger . warn ( traceback . format_exc ( ) ) try : timeout = next ( network_timeouts ) logger . warn ( "Network error, will retry in %ss..." % timeout ) time . sleep ( timeout ) continue except StopIteration : raise self . NetworkError ( ) except self . UnderMaintenance as e : try : timeout = next ( maintenance_timeouts ) logger . warn ( "Writer is under maintenance, will retry in %ss..." % timeout ) time . sleep ( timeout ) continue except StopIteration : raise e
Send request to writer service.
Send request to writer service .