4
4
import pytz
5
5
import os
6
6
import time
7
+ import json
7
8
8
9
import firebase_admin
9
10
from firebase_admin import credentials
@@ -109,6 +110,7 @@ def upload_data(item: dict):
109
110
110
111
# 염분 수질관측소 코드별로 반복문 실행
111
112
for key in wtqltObsrvtCd :
113
+
112
114
print (key , wtqltObsrvtCd [key ])
113
115
114
116
parameters = {
@@ -124,7 +126,22 @@ def upload_data(item: dict):
124
126
125
127
print ("parameters: " , parameters )
126
128
127
- response = requests .get (url = END_POINT , params = parameters ).json ()
129
+ response = requests .get (url = END_POINT , params = parameters )
130
+ print ("First Response Code: " , response .status_code )
131
+
132
+ count = 1
133
+ while response .status_code != 200 :
134
+ print ("Retry Count: " , count )
135
+ response = requests .get (url = END_POINT , params = parameters )
136
+ print ("Response Code: " , response .status_code )
137
+ count += 1
138
+ time .sleep (1 )
139
+
140
+ if count > 100 :
141
+ print ("API Error" )
142
+ continue
143
+
144
+ response = json .loads (response .text )
128
145
129
146
print ("Response:" , response ['response' ]['header' ])
130
147
print ("data Length: " , response ['response' ]['body' ]['totalCount' ])
@@ -140,5 +157,3 @@ def upload_data(item: dict):
140
157
upload_data (data )
141
158
142
159
print ("Data Upload Success at" , wtqltObsrvtCd [key ], "\n \n " )
143
-
144
- time .sleep (25 )
0 commit comments