web.py 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. #!/usr/bin/env python3
  2. import tasks
  3. from flask import Flask, jsonify
  4. from rq import Queue
  5. from rq.job import Job
  6. from worker import conn
  7. PORT = 8981
  8. BASE_PATH="/back" #changes based on webserver
  9. app = Flask(__name__)
  10. @app.route(BASE_PATH + '/')
  11. def index():
  12. return "Hello world"
  13. @app.route(BASE_PATH + '/raw')
  14. def raw_list():
  15. ret={'list':
  16. [{'file':'movie-1231547519.flv', 'length':'1:14:32', 'date': "2016,7,13"},
  17. {'file':'movie-1231111111.flv', 'length':'0:14:32', 'date': "2016-7-12"} ]
  18. }
  19. return jsonify(ret)
  20. @app.route(BASE_PATH + '/job')
  21. def job():
  22. # func=tasks.cut_video , args=("/home/david/movie-1467033043.flv","0:45","1:48:00","/home/david/salida-cortada.mp4",), result_ttl=5000
  23. #job = tasks.long_job.delay("test")
  24. job = tasks.cut_video.delay("/home/david/movie-1467033043.flv","0:45","1:48:00","/home/david/salida-cortada.mp4")
  25. # job = tasks.upload_video.delay("titulo","/home/david/photo_2016-07-10_13-49-56.jpg","/home/david/movie-1467033043.flv")
  26. ret = {"id":job.get_id()}
  27. return jsonify(ret)
  28. @app.route(BASE_PATH+"/results/<job_key>", methods=['GET'])
  29. def get_results(job_key):
  30. print(job_key)
  31. job = Job.fetch(job_key, connection=conn)
  32. if job.is_finished:
  33. return str(job.result), 200
  34. else:
  35. return "%s" % json.dumps(job.meta) , 202
  36. @app.route(BASE_PATH + '/cut')
  37. def cut_list():
  38. ret=[]
  39. return jsonify(ret)
  40. @app.route(BASE_PATH + '/uploaded')
  41. def uploaded_list():
  42. ret=[]
  43. return jsonify(ret)
  44. if __name__ == '__main__':
  45. app.run(host="0.0.0.0",port=PORT, debug=True)