calc.py

from celery import Celery
import requests
import pandas as pd

celery = Celery(
        'calc',
        backend='redis://localhost',
        broker='pyamqp://guest@localhost//'
    )

@celery.task()
def getTwitterUser(topic, headers):
    res = requests.get(f"https://oauth.reddit.com/r/{topic}/hot", headers=headers)
    return res.json()

@celery.task()
def genReport(results):
    dfs=[]

    for result in results:
        for post in result['data']['children']:
            
            df=pd.DataFrame([{"title":post['data']['title'], "author":post['data']['author_fullname']}])

            dfs.append(df)
    
    df = pd.concat(dfs, axis=0)
    df.index=list(range(df.shape[0]))
        
    return df.to_json()