Update app.py
Browse files
app.py
CHANGED
@@ -11,8 +11,18 @@ exchange = ccxt.mexc({
|
|
11 |
'enableRateLimit': True,
|
12 |
})
|
13 |
|
|
|
|
|
|
|
14 |
def fetch_ohlcv_data(symbol, timeframe, limit):
|
15 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
16 |
|
17 |
def data_to_dataframe(data):
|
18 |
df = pd.DataFrame(data, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
|
|
|
11 |
'enableRateLimit': True,
|
12 |
})
|
13 |
|
14 |
+
#def fetch_ohlcv_data(symbol, timeframe, limit):
|
15 |
+
#return exchange.fetch_ohlcv(symbol, timeframe, since=None, limit=limit)
|
16 |
+
|
17 |
def fetch_ohlcv_data(symbol, timeframe, limit):
|
18 |
+
data = []
|
19 |
+
start_time = None
|
20 |
+
while len(data) < limit:
|
21 |
+
ohlcv_data = exchange.fetch_ohlcv(symbol, timeframe, since=start_time, limit=limit)
|
22 |
+
data.extend(ohlcv_data)
|
23 |
+
start_time = ohlcv_data[-1][0] + 1
|
24 |
+
return data
|
25 |
+
|
26 |
|
27 |
def data_to_dataframe(data):
|
28 |
df = pd.DataFrame(data, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
|