Function processed_df

process.py:317–333

()

def processed_df():
    df = create_pandas_redis()

    print('Processing -> Getting Tickers')
    df['tickers'] = parallelize_on_rows(df, p_tickers)
    
    print('Processing -> NLP processing')
    df["ents"], df["sentiment"] = zip(*df.apply(nlp_processing, axis=1))
    #df_nlps = parallelize_on_rows(df, nlp_processing)
    #df["ents"], df["sentiment"] = zip(*df_nlps)

    df_3, df_1 = df[df.apply(partial(day_filter, day=3), axis=1)], df[df.apply(partial(day_filter, day=1), axis=1)]

    print('Processing -> Calculating for each ticker')
    timed_df = calculate_df_timed(df, time_mins=30)
    plot_df(timed_df)
    return calculate_df(df), calculate_df(df_3), calculate_df(df_1), df