Тайм-аут для клиентских запросов xmlrpclib - PullRequest
Новая
       16

Тайм-аут для клиентских запросов xmlrpclib

4 голосов
/ 11 марта 2010

Я использую Python xmlrpclib для отправки запросов в службу xml-rpc.

Есть ли способ установить время ожидания клиента, чтобы мои запросы не зависали вечно, когда сервер недоступен?

Я знаю, что могу глобально установить время ожидания сокета с помощью socket.setdefaulttimeout(), но это не является предпочтительным.

Ответы [ 4 ]

12 голосов
/ 11 марта 2010

Чистый подход заключается в определении и использовании пользовательского транспорта, например: ! это будет работать только для python2.7! 

import xmlrpclib, httplib

class TimeoutTransport(xmlrpclib.Transport):
    timeout = 10.0
    def set_timeout(self, timeout):
        self.timeout = timeout
    def make_connection(self, host):
        h = httplib.HTTPConnection(host, timeout=self.timeout)
        return h

t = TimeoutTransport()
t.set_timeout(20.0)
server = xmlrpclib.Server('http://time.xmlrpc.com/RPC2', transport=t)

Существует пример определения и использования пользовательского транспорта в документах , хотя он использует его для других целей (доступ через прокси, а не для установки тайм-аутов), этот код в основном вдохновлен тем, что пример.

8 голосов
/ 16 мая 2011

doh, чтобы заставить это работать в python2.6 +, сделайте это: 

class HTTP_with_timeout(httplib.HTTP):
    def __init__(self, host='', port=None, strict=None, timeout=5.0):
        if port == 0: port = None
        self._setup(self._connection_class(host, port, strict, timeout=timeout))

    def getresponse(self, *args, **kw):
        return self._conn.getresponse(*args, **kw)

class TimeoutTransport(xmlrpclib.Transport):
    timeout = 10.0
    def set_timeout(self, timeout):
        self.timeout = timeout
    def make_connection(self, host):
        h = HTTP_with_timeout(host, timeout=self.timeout)
        return h
5 голосов
/ 28 июня 2011

Почему бы и нет: 

class TimeoutTransport(xmlrpclib.Transport):

def setTimeout(self, timeout):
    self._timeout = timeout

def make_connection(self, host):
    return httplib.HTTPConnection(host, timeout=self._timeout)

В конце концов, HTTP и HTTPS кажутся не более чем классами совместимости для более старых версий Python.

3 голосов
/ 07 июня 2013

Альтернативная реализация, которая будет совместима с python 2.7, будет выглядеть следующим образом (с комментарием, содержащим то, что вам нужно, если вы используете python 2.6): 

import socket
import xmlrpclib

class TimeoutTransport (xmlrpclib.Transport):
    """
    Custom XML-RPC transport class for HTTP connections, allowing a timeout in
    the base connection.
    """

    def __init__(self, timeout=socket._GLOBAL_DEFAULT_TIMEOUT, use_datetime=0):
        xmlrpclib.Transport.__init__(self, use_datetime)
        self._timeout = timeout

    def make_connection(self, host):
        # If using python 2.6, since that implementation normally returns the 
        # HTTP compatibility class, which doesn't have a timeout feature.
        #import httplib
        #host, extra_headers, x509 = self.get_host_info(host)
        #return httplib.HTTPConnection(host, timeout=self._timeout)

        conn = xmlrpclib.Transport.make_connection(self, host)
        conn.timeout = self._timeout
        return conn

# Example use
t = TimeoutTransport(timeout=10)
server = xmlrpclib.ServerProxy('http://time.xmlrpc.com/RPC2', transport=t)

Использование супер-метода позволит базовой реализации 2.7 поддерживать свою функцию поддержки активности HTTP / 1.1, которую он определяет.

Следует отметить, что если вы пытаетесь использовать XML-RPC через соединение / адрес https, замените xmlrpc.SafeTransport ссылки на xmlrpc.Transport и, если вы используете реализацию 2.6, используйте httplib.HTTPSConnection.

...