10-28-202101:10點
我有一個簡單的API請求查詢一個表和索取數據,然後適合dataframe。可能發生,不能由於不同的原因。如何重試假設5次當任何錯誤發生?
這是一個api請求:
df = spark.createDataFrame (sf.bulk.MyTable。查詢(“選擇Id,狀態從MyTable”))
10-28-2021於下午
@Bartosz Wachocki,
使用超時,重試時間間隔,遞歸和異常處理
下麵的偽代碼
超時= 300
def exec_query(查詢、超時):
試一試:
df = spark.createDataFrame (sf.bulk.MyTable.query(查詢)
除了:
如果超時> 0:
睡眠(60)
exec_query(查詢)
timeout =超時- 60
其他:
print(“超時”)
打破;
從未顯出
加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。
點擊在這裏注冊今天,加入!
參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。