Background tweeting with Flask-RQ

hasjob/__init__.py

@@ -2,6 +2,7 @@
 # -*- coding: utf-8 -*-
 
 from flask import Flask
+from flask.ext.rq import RQ
 from flask.ext.mail import Mail
 from flask.ext.lastuser import Lastuser
 from baseframe import baseframe, assets, Version
@@ -31,6 +32,7 @@
 # Configure the app
 def init_for(env):
     coaster.app.init_app(app, env)
+    RQ(app)
     if app.config.get('SERVER_NAME'):
         subdomain = 'static'
     else:

hasjob/twitter.py

@@ -1,10 +1,15 @@
+# -*- coding: utf-8 -*-
+
+from flask.ext.rq import job
 from tweepy import OAuthHandler, API
 import bitlyapi
 import urllib2
 import json
 import re
 from hasjob import app
 
+
+@job('hasjob')
 def tweet(title, url, location=None):
     auth = OAuthHandler(app.config['TWITTER_CONSUMER_KEY'], app.config['TWITTER_CONSUMER_SECRET'])
     auth.set_access_token(app.config['TWITTER_ACCESS_KEY'], app.config['TWITTER_ACCESS_SECRET'])

hasjob/views/listing.py

@@ -440,7 +440,7 @@ def confirm_email(hashid, key):
             db.session.commit()
             if app.config['TWITTER_ENABLED']:
                 try:
-                    tweet(post.headline, url_for('jobdetail', hashid=post.hashid,
+                    tweet.delay(post.headline, url_for('jobdetail', hashid=post.hashid,
                         _external=True), post.location)
                     flash("Congratulations! Your job listing has been published and tweeted",
                           "interactive")

requirements.txt

@@ -4,6 +4,7 @@ Flask-WTF
 Flask-Mail
 Flask-Assets
 Flask-Uploads
+Flask-RQ
 Pillow
 pytz
 markdown

rq.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+
+rqworker -c rqdev hasjob

rqdev.py

@@ -0,0 +1,16 @@
+from urlparse import urlparse
+
+from hasjob import init_for, app
+
+init_for('dev')
+
+REDIS_URL = app.config.get('REDIS_URL', 'redis://localhost:6379/0')
+
+# REDIS_URL is not taken by setup_default_arguments function of rq/scripts/__init__.py
+# so, parse it into pieces and give it
+
+r = urlparse(REDIS_URL)
+REDIS_HOST = r.hostname
+REDIS_PORT = r.port
+REDIS_PASSWORD = r.password
+REDIS_DB = 0

rqinit.py

@@ -0,0 +1,15 @@
+from urlparse import urlparse
+
+from hasjob import init_for, app
+
+init_for('production')
+REDIS_URL = app.config.get('REDIS_URL', 'redis://localhost:6379/0')
+
+# REDIS_URL is not taken by setup_default_arguments function of rq/scripts/__init__.py
+# so, parse that into pieces and give it
+
+r = urlparse(REDIS_URL)
+REDIS_HOST = r.hostname
+REDIS_PORT = r.port
+REDIS_PASSWORD = r.password
+REDIS_DB = 0