especificos-videos/back/web.py

#!/usr/bin/env python3
import json
import tasks

from db import db
from flask import Flask, jsonify
from rq import Queue
from rq.job import Job
from worker import conn

PORT = 8981
BASE_PATH="/back" #changes based on webserver
app = Flask(__name__)
d=db()
@app.route(BASE_PATH + '/')
def index():
    return "Hello world"

@app.route(BASE_PATH + '/raw')
def raw_list():
    ret={'list': d.raw() }
    return jsonify(ret)

@app.route(BASE_PATH + '/job')
def job():
    # func=tasks.cut_video , args=("/home/david/movie-1467033043.flv","0:45","1:48:00","/home/david/salida-cortada.mp4",), result_ttl=5000
    #job = tasks.long_job.delay("test")
    job = tasks.cut_video.delay("/home/david/movie-1467033043.flv","0:45","1:48:00","/home/david/salida-cortada.mp4")
#    job = tasks.upload_video.delay("titulo","/home/david/photo_2016-07-10_13-49-56.jpg","/home/david/movie-1467033043.flv")

    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 "%s" % json.dumps(job.meta) , 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)