Skip to content

Instantly share code, notes, and snippets.

@segphault segphault/app.py
Created Dec 5, 2014

Embed
What would you like to do?
Flask application that serves RethinkDB data in CSV format
#!/usr/bin/env python
from csvkit.convert.js import json2csv
from collections import OrderedDict
from flask import Flask
import rethinkdb as r
import json, StringIO
config = {
"port": 8096,
"host": "0.0.0.0",
"database": {
"host": "localhost",
"port": 28015,
"db": "quake"
}
}
app = Flask(__name__)
feedUrl = "earthquake.usgs.gov/earthquakes/feed/v1.0/summary/4.5_month.geojson"
refresh = r.table("quakes").insert(r.http(feedUrl)["features"], conflict="replace")
try:
conn = r.connect(**config["database"])
r.db_create(config["database"]["db"]).run(conn)
r.table_create("quakes").run(conn)
refresh.run(conn)
except Exception as e:
if "already exists" not in e.message: print e
finally: conn.close()
@app.route("/quakes")
def quakesJSON():
conn = r.connect(**config["database"])
output = r.table("quakes") \
.group(r.epoch_time(r.row["properties"]["time"] / 1000).date()) \
.ungroup().merge({"count": r.row["reduction"].count()}) \
.run(conn)
conn.close();
return json.dumps([OrderedDict([
["date", item["group"].strftime("%D")],
["count", item["count"]]]) for item in output])
@app.route("/quakes/csv")
def quakesCSV():
return json2csv(StringIO.StringIO(quakesJSON()))
if __name__ == "__main__":
app.run(host=config["host"], port=config["port"], debug=True)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.