especificos-videos/back/web.py

#!/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():
    # func=tasks.cut_video , args=("/home/david/movie-1467033043.flv","0:45","1:48:00","/home/david/salida-cortada.mp4",), result_ttl=5000
    job = q.enqueue_call(
            func=tasks.upload_video,
            args=("titulo","/home/david/photo_2016-07-10_13-49-56.jpg","/home/david/movie-1467033043.flv",),
            timeout=3600*2,
            result_ttl=3600*2
        )
    #con decorator seria:
    #tasks.upload_video.delay(..args..)
    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
        #return "Nay! %s - %s" % (job.meta.get('video_id'),job.meta.get('status')) , 202
        #return "Nay! %s - %s" % (job.meta.get('video_id'),job.meta.get('status')) , 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)