Как использовать PANDAS и MySql одновременно в моей БД? - PullRequest
0 голосов
/ 25 ноября 2018

Я новенькая как программист, и вы пробуете только 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 тысяч записей, и я хочу сохранять только ограниченные записи, когда меняю только цену, а не все звонки, которые я прошу проконсультироваться, если есть изменение цены.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...