| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- #!/usr/bin/env python3
- import datetime
- import json
- import urllib
- from db import db
- from flask import Flask, abort, jsonify, request
- import time
- import tasks
- from rq import Queue
- from rq.job import Job
- from worker import conn
- q = Queue(connection=conn)
- PORT = 8981
- BASE_PATH="/back" #changes based on webserver
- app = Flask(__name__)
- @app.route(BASE_PATH + '/')
- def index():
- return "Hello world"
- @app.route(BASE_PATH + '/raw')
- def raw_list():
- ret={'list':
- [{'file':'movie-1231547519.flv', 'length':'1:14:32', 'date': "2016,7,13"},
- {'file':'movie-1231111111.flv', 'length':'0:14:32', 'date': "2016-7-12"} ]
- }
- return jsonify(ret)
- @app.route(BASE_PATH + '/job')
- def job():
- job = q.enqueue_call(
- func=tasks.long_job, args=("testarg",), result_ttl=5000
- )
- ret = {"id":job.get_id()}
- return jsonify(ret)
- @app.route(BASE_PATH+"/results/<job_key>", methods=['GET'])
- def get_results(job_key):
- print(job_key)
- job = Job.fetch(job_key, connection=conn)
- if job.is_finished:
- return str(job.result), 200
- else:
- return "Nay! %s" % job.meta.get('progress') , 202
- @app.route(BASE_PATH + '/cut')
- def cut_list():
- ret=[]
- return jsonify(ret)
- @app.route(BASE_PATH + '/uploaded')
- def uploaded_list():
- ret=[]
- return jsonify(ret)
- if __name__ == '__main__':
- app.run(host="0.0.0.0",port=PORT, debug=True)
|