|
from news_extractor import get_news |
|
from db_operations import DBOperations |
|
import json |
|
from flask import Flask, Response |
|
from flask_cors import cross_origin, CORS |
|
import logging |
|
|
|
app = Flask(__name__) |
|
CORS(app) |
|
logging.warning('Initiated') |
|
|
|
|
|
@app.route("/") |
|
@cross_origin() |
|
def update_news(): |
|
status_json = "{'status':'success'}" |
|
status_code = 200 |
|
try: |
|
db = DBOperations() |
|
news_df = get_news() |
|
news_json = [*json.loads(news_df.reset_index(drop=True).to_json(orient="index")).values()] |
|
db.insert_news_into_db(news_json) |
|
except: |
|
status_json = "{'status':'failure'}" |
|
status_code = 500 |
|
return Response(status_json, status=status_code, mimetype='application/json') |
|
|
|
|
|
if __name__ == "__main__": |
|
app.run(host="0.0.0.0", port=7860, timeout=120, workers=1, threads=1) |
|
|
