newsapi.py

from flask import Flask, request
from celerynews import getNewsData, genReport
from celery import chord
from default_settings import *
import requests

app = Flask(__name__)

@app.route('/api/send', methods=['GET', 'POST'])
def send():

    countries = request.get_json()["countries"]

    ''' Fast version '''
    tasks = [getNewsData.s(country) for country in countries]
    res = chord(tasks)(genReport.s())
    df = res.get()

    '''Slow version'''
    # reslst=[]
    # for ye in countries:
    #     res = requests.request("GET", "https://newsapi.org/v2/top-headlines",
    #     params={"country":ye, "apiKey":"<API_KEY>"})
    #     reslst.append(res.json())

    # df = genReport.delay(reslst).get()

    return df
   
    
if __name__ == '__main__':
    app.run(debug=True, host='0.0.0.0', port=5000)