diff --git a/weex/抓取数据.py b/weex/抓取数据.py index ce84d04..7c25901 100644 --- a/weex/抓取数据.py +++ b/weex/抓取数据.py @@ -36,44 +36,48 @@ klineId = None klineTime = None contractId = None -for i in range(50): - print(i) - params = { - 'languageType': '1', - 'sign': 'SIGN', - 'timeZone': 'string', - 'contractId': '10000002', - 'productCode': 'ethusdt', - 'priceType': 'LAST_PRICE', - 'klineType': 'MINUTE_15', - 'limit': '329', - } +while True: - if klineId: - params['nextKey.klineId'] = klineId - params['nextKey.contractId'] = contractId + for i in range(10): + print(i) + params = { + 'languageType': '1', + 'sign': 'SIGN', + 'timeZone': 'string', + 'contractId': '10000002', + 'productCode': 'ethusdt', + 'priceType': 'LAST_PRICE', + 'klineType': 'MINUTE_15', + 'limit': '329', + } - if klineTime: - params['nextKey.klineTime'] = klineTime + if klineId: + params['nextKey.klineId'] = klineId + params['nextKey.contractId'] = contractId - response = requests.get('https://http-gateway1.janapw.com/api/v1/public/quote/v1/getKlineV2', params=params, - headers=headers) + if klineTime: + params['nextKey.klineTime'] = klineTime - klineId = response.json()["data"]["nextKey"]["klineId"] - klineTime = response.json()["data"]["nextKey"]["klineTime"] - contractId = response.json()["data"]["nextKey"]["contractId"] + response = requests.get('https://http-gateway1.janapw.com/api/v1/public/quote/v1/getKlineV2', params=params, + headers=headers) - for data in response.json()["data"]["dataList"]: - # print(data) + klineId = response.json()["data"]["nextKey"]["klineId"] + klineTime = response.json()["data"]["nextKey"]["klineTime"] + contractId = response.json()["data"]["nextKey"]["contractId"] - Weex.get_or_create( - id=int(data[4]), - defaults={ - 'open': float(data[3]), - 'high': float(data[1]), - 'low': float(data[2]), - 'close': float(data[0]), - } - ) + for data in response.json()["data"]["dataList"]: + # print(data) - # time.sleep(1) + Weex.get_or_create( + id=int(data[4]), + defaults={ + 'open': float(data[3]), + 'high': float(data[1]), + 'low': float(data[2]), + 'close': float(data[0]), + } + ) + + # time.sleep(1) + + time.sleep(3600)