vulcan25/app.py

## app.py
from flask import Flask, redirect, url_for, render_template_string
from time import sleep

from rq import Queue
from rq.job import Job

from redis import Redis

r = Redis(host='redisserver')
q = Queue(connection=r)

def slow_func(data):
    sleep(5)
    return 'Processed %s' % (data,)

app = Flask(__name__)

template_str='''<html>
    <head>
      {% if refresh %}
      <meta http-equiv="refresh" content="5">
      {% endif %}
    </head>
    <body>{{result}}</body>
    </html>'''

def get_template(data, refresh=False):
    return render_template_string(template_str, result=data, refresh=refresh)

@app.route('/result/<string:id>')
def result(id):
    job = Job.fetch(id, connection=r)
    status = job.get_status()
    if status in ['queued', 'started', 'deferred', 'failed']:
        return get_template(status, refresh=True)
    elif status == 'finished':
        result = job.result
        # If this is a string, we can simply return it:
        return get_template(result)

@app.route('/process/<string:data>')
def process(data):
    job = q.enqueue(slow_func, data)
    return redirect(url_for('result', id=job.id))
	from flask import Flask, redirect, url_for, render_template_string
	from time import sleep

	from rq import Queue
	from rq.job import Job

	from redis import Redis

	r = Redis(host='redisserver')
	q = Queue(connection=r)

	def slow_func(data):
	sleep(5)
	return 'Processed %s' % (data,)

	app = Flask(__name__)

	template_str='''<html>
	<head>
	{% if refresh %}
	<meta http-equiv="refresh" content="5">
	{% endif %}
	</head>
	<body>{{result}}</body>
	</html>'''

	def get_template(data, refresh=False):
	return render_template_string(template_str, result=data, refresh=refresh)

	@app.route('/result/<string:id>')
	def result(id):
	job = Job.fetch(id, connection=r)
	status = job.get_status()
	if status in ['queued', 'started', 'deferred', 'failed']:
	return get_template(status, refresh=True)
	elif status == 'finished':
	result = job.result
	# If this is a string, we can simply return it:
	return get_template(result)

	@app.route('/process/<string:data>')
	def process(data):
	job = q.enqueue(slow_func, data)
	return redirect(url_for('result', id=job.id))