with open("student.csv", "r") as csv_ledger: r = csv.DictReader(csv_ledger) data = [dict(d) for d in r ] groups = {} for k, g in groupby(data, lambda r: (r['name'])): items = [] for i in g: #data processing try: post_api = requests.post(ENDPOINT_URL, json=groups, headers=headers) except requests.ConnectionError: print("Something went wrong") finally: print("resume post request")目前，當互聯網連接斷開時，我的代碼將無法恢復發布請求。如果我使用 try 和 exception，它就不起作用。
2 回答
慕斯709654
TA貢獻1840條經驗 獲得超5個贊
不確定您是否可以在沒有服務器端實現的情況下隨意恢復，但您可以從客戶端恢復。這是一個簡單的阻塞示例，但您可能希望將其放入線程中。
import csv
import socket
from time import sleep
import requests
def is_internet_on():
try:
socket.setdefaulttimeout(3)
socket.socket(socket.AF_INET, socket.SOCK_STREAM).connect(('1.1.1.1', '8080'))
return True
except:
return False
def do_call_later(url, headers, body):
while not is_internet_on():
sleep(5)
requests.post(url, headers=headers, body=body)
with open("student.csv", "r") as csv_ledger:
r = csv.DictReader(csv_ledger)
data = [dict(d) for d in r]
groups = {}
for k, g in groupby(data, lambda r: (r['name'])):
items = []
for i in g:
# data processing
pass
try:
timeout_arg = (
# first tuple value is the connection timeout,
# how long to wait before initial connection is established
1.0,
# second tuple value is the read timeout, this is how long
# the client will wait after the initial connection
# before dropping the connection because no response was sent
1.0
)
post_api = requests.post(ENDPOINT_URL, json=groups, headers=headers, timeout=timeout_arg)
except requests.ConnectionError:
do_call_later(ENDPOINT_URL, headers, groups)
finally:
print("resume post request")
編輯：超時調用的文檔：https : //github.com/kennethreitz/requests/blob/master/requests/api.py#L34
添加回答
舉報
0/150
提交
取消