import numpy
#import talib
import requests
import json
import time
import mysql.connector
#from matplotlib.finance import candlestick2_ohlc
#i#mport matplotlib.animation as animation
#import matplotlib.pyplot as plt
#import matplotlib.ticker as ticker
from datetime import datetime
def update_mysql():
PAIR = 'BTC_USD'
db = mysql.connector.connect(host="localhost", user="u", passwd="secret", db="exmo")
cur = db.cursor()
resource = requests.get('https://api.exmo.com/v1/trades/?pair=%s&limit=500' % PAIR)
#resource = requests.get('https://api.exmo.com/v1/trades/?pair=%s&limit=10000' % PAIR)
data = json.loads(resource.text)
#print(data[PAIR][1])
chart_data = {} # сформируем словарь с ценой закрытия по PERIOD минут
#print(data[PAIR][1]['date'])
#print(int(float(data[PAIR][1]['date'])/(PERIOD*60))*(PERIOD*60))
#print('-----------------------------')
for item in reversed(data[PAIR]):
_SQL = """insert ignore into trade
(trade_id, type, amount, quantity, date, price)
values
(%s,%s,%s,%s,%s,%s)"""
cur.execute(_SQL, (item['trade_id'],item['type'],item['amount'],item['quantity'],item['date'],item['price']))
db.commit()
#cur.close()
#db.close()
FLAG = False
if FLAG:
_SQL = """select * from trade"""
cur.execute(_SQL)
for row in cur.fetchall():
print(row)
db.commit()
cur.close()
db.close()
return()
# Бесконечный цикл процесса - основная логика
while True:
try:
update_mysql()
time.sleep(1)
print('работаем!')
except Exception as e:
print(e)
В обновлялке стоит лимит 500 записей, поставьте 10000 что бы не было пропусков, а затем поставьте обратно 500.
#import talib
import requests
import json
import time
import mysql.connector
#from matplotlib.finance import candlestick2_ohlc
#i#mport matplotlib.animation as animation
#import matplotlib.pyplot as plt
#import matplotlib.ticker as ticker
from datetime import datetime
def update_mysql():
PAIR = 'BTC_USD'
db = mysql.connector.connect(host="localhost", user="u", passwd="secret", db="exmo")
cur = db.cursor()
resource = requests.get('https://api.exmo.com/v1/trades/?pair=%s&limit=500' % PAIR)
#resource = requests.get('https://api.exmo.com/v1/trades/?pair=%s&limit=10000' % PAIR)
data = json.loads(resource.text)
#print(data[PAIR][1])
chart_data = {} # сформируем словарь с ценой закрытия по PERIOD минут
#print(data[PAIR][1]['date'])
#print(int(float(data[PAIR][1]['date'])/(PERIOD*60))*(PERIOD*60))
#print('-----------------------------')
for item in reversed(data[PAIR]):
_SQL = """insert ignore into trade
(trade_id, type, amount, quantity, date, price)
values
(%s,%s,%s,%s,%s,%s)"""
cur.execute(_SQL, (item['trade_id'],item['type'],item['amount'],item['quantity'],item['date'],item['price']))
db.commit()
#cur.close()
#db.close()
FLAG = False
if FLAG:
_SQL = """select * from trade"""
cur.execute(_SQL)
for row in cur.fetchall():
print(row)
db.commit()
cur.close()
db.close()
return()
# Бесконечный цикл процесса - основная логика
while True:
try:
update_mysql()
time.sleep(1)
print('работаем!')
except Exception as e:
print(e)
В обновлялке стоит лимит 500 записей, поставьте 10000 что бы не было пропусков, а затем поставьте обратно 500.
Комментариев нет:
Отправить комментарий