Как то я задавал вопроc: Как сделать запрос по истечению временного интервала в Python? Спасибо всем за ответы! Очень помогли! Но я решил сам поэкспериментировать, и, порывшись в интернете, решил решить эту задачу с помощью signals. Вот пример:
Сначала пишем такую вот функцию короткую функцию - это хэндлер, нужен для signals. Все, что он умеет делать, это выдавать исключение:
def _handler(signum, frame):
raise IOError("Waiting for the response too long!!!")
Потом создаем декоратор:
def repeat_request(func):
"""
The decorator for functions and methods that unavailable to reach response for the first attempt
"""
def wrapper(*args, **kwargs):
while True:
try:
signal.signal(signal.SIGALRM, _handler)
signal.alarm(5)
response = func(*args, **kwargs)
except IOError:
continue
else:
break
return response
return wrapper
Метод get_image_url(self)
находится в классе. Его мы и декорируем с попощью созданого нами декоратора:
@repeat_request
get_image_url(self)
Хотелось бы закричать "Ура!", так как вроде бы все работает, как и ожидалось: Исполняется запрос с помощью get_image_url
, и, если нету ответа в течении 5 секунд, он делается вновь. Так может быть до бесконечности, пока ми не получим значение от get_image_url
Но вот незадача... После вызова get_image_url я запускаю другую функцию (назовем ее foo()
), которая работает очень долго (но так и должно быть). Почему-то этот декоратор измеряет время и для нее и выбрысывается исключение "Waiting for the response too long!!!"
Это мое первое использование signals. Поэтому я четко не понимаю механизмы, как это работает. Функцию foo()
я в декоратор не оборачивал, естественно. Но время замеряется для нее тоже, что выглядит довольно странно... Пытался больше сам разобраться с signals, но документация скудна и непонятна. Если кто разбирается - просьба помочь
get_image_url()
вызывает не кооперирующее C расширение. Ответ сmultiprocessing.Process
продолжает работать и в этом случае.