Несколько случайных запросов POST в Python

Question

У меня есть эта программа, которая отправляет запрос GET с использованием библиотеки запросов и затем отправляет запрос POST на другой сервер.

import requests 

# inside the loop : 
headers = {'charset':'utf-8','Content-Type':'application/json'} 
url = "http://someurl/_get_v2.php" 
data = jenal 

try : 
    resp = requests.post(url,json=data,headers=headers, timeout=(connect_timeout,read_timeout)) 

    print "Post request sent" 
# If a connection error occurs, start from the beginning of the loop 
except requests.exceptions.ConnectionError as e: 
    continue 
# If a read_timeout error occurs, start from the beginning of the loop 
except requests.exceptions.ReadTimeout as e: 
    continue 
time.sleep(10) 

Это часть POST от основного контура. Я использовал try и за исключением случаев, когда программа задерживается, я не хочу, чтобы она останавливалась на любую ошибку, но обновляется и продолжается с самого начала цикла и так далее навсегда. Логично, что программа должна быть прекрасной, но при внезапном множестве задержек программа одновременно отправляет несколько запросов POST.

Например: журнал должен быть таким: 10 отправлено. 20 отправлено. 30 отправлено. 45 отправлено (задержка 5 секунд). 55 послало

но что это происходит: 10 послало 20 послало 30 послала задержки ..
45 послало 45 послали 45 посланных (несколько копий данных посылаются в то же самое время, которое развращает мою базу данных) 55 отправлено

Как я могу предотвратить дополнительные копии?

Это первая часть программы. В случае, если есть что-нибудь в почтовом части, эта часть повторяется, и я могу видеть на печать каждый раз:

connect_timeout = 3.05 
read_timeout = 2 

while True: 
loop_time_start = time.time() 
# GET 

url_source = 'http://something/api_json.asp?cmd=list_metering&auth=YWRtaW46YWRtaW4=' 
try: 
    url = requests.get(url_source) 
    print "GET request sent" 
except requests.exceptions.ConnectionError as e: continue 

Answer 1

I would recommend looking at the approved answer on this question.

Answer 2

Что делать, если вы добавить таймер к коду.

import requests 
from datetime import datetime, time 

posting = False 

# inside the loop : 

if not posting: 
    posting = True 

    headers = {'charset':'utf-8','Content-Type':'application/json'} 
    url = "http://someurl/_get_v2.php" 
    data = jenal 

    start = datetime.now() 
    try : 
     resp = requests.post(url,json=data,headers=headers,timeout=(connect_timeout,read_timeout)) 

     print "Post request sent" 

     posting = False 

    except requests.exceptions.ConnectionError as e: 
     # If you continue here, then there will be no sleep. 
     # If your POST fails straight away, it tries again straight away. 

     # You should print/log here so you know which exception is being caught. 

     # Add Timer 
     end = datetime.combine(start.date(), time(0)) 

     ShouldISleep(start, end) 

     posting = False 

     continue 

    except requests.exceptions.ReadTimeout as e: 
     # If you continue here, then there will be no sleep. 
     # If your POST fails straight away, it tries again straight away. 

     # You should print/log here so you know which exception is being caught. 

     # Add Timer 
     end = datetime.combine(start.date(), time(0)) 

     ShouldISleep(start, end) 

     posting = False 

     continue 

    time.sleep(10) 

Создание функции

def ShouldISleep(t1, t2): 
    passed = (t1 - t2).seconds 
    if passed < 10: 
     time.sleep(10 - passed)