Я новенькая как программист, и вы пробуете только Python и MySQL, и у меня есть проблема, я надеюсь, что смогу найти помощь здесь.
Мой код:
df = pd.DataFrame.from_dict(arr, orient='columns')
df['EMA_Corta'] = df['AskTop'].ewm(span=EMA_Corta, adjust=False).mean()
df['EMA_Larga'] = df['AskTop'].ewm(span=EMA_Larga, adjust=False).mean()
df['Señal'] = np.where(df['EMA_Corta'] > df['EMA_Larga'], 1.0, 0.0)
df['positions'] = df['Señal'].diff().fillna(0)
df['Señal_Trading'] = df['positions'].fillna(0)
df['Precio_transaccion'] = np.where(df['Señal_Trading'] == 1, df['Price'], df['Price'])
df['Posicion'] = np.where(df['Señal']==1, "BUY","SELL")
df.to_sql(name='TradingSignals',con=engine,if_exists='append',index=False)
print(df)
if index == 1:
data = GetObject(precioActual, bidTop, askTop)
arr.append(data)
df = pd.DataFrame.from_dict(arr, orient='columns')
df['EMA_Corta'] = df['AskTop'].ewm(span=EMA_Corta, adjust=False).mean()
df['EMA_Larga'] = df['AskTop'].ewm(span=EMA_Larga, adjust=False).mean()
df['Señal'] = np.where(df['EMA_Corta'] > df['EMA_Larga'], 1.0, 0.0)
df['positions'] = df['Señal'].diff().fillna(0)
df['Señal_Trading'] = df['positions'].fillna(0)
df['Precio_transaccion'] = np.where(df['Señal_Trading'] == 1, df['Price'], df['Price'])
df['Posicion'] = np.where(df['Señal']==1, "BUY","SELL") #VARCHAR
df.to_sql(name='TradingSignals',con=engine,if_exists='append',index=False)
print(df)
Этот код выполняет вызовы API, и я получаю цену, исходя из этой цены я делаю очень простую стратегию.Эта стратегия - то, что я хочу сохранить в моей базе данных mysql как фрейм данных.Проблема в том, что это экономит мне 90 тысяч записей, и я хочу сохранять только ограниченные записи, когда меняю только цену, а не все звонки, которые я прошу проконсультироваться, если есть изменение цены.