One Paragraph of project description goes here
These instructions will get you a copy of the project up and running on your local machine for development and testing purposes. See deployment for notes on how to deploy the project on a live system.
| import sqlite3 | |
| # open connection and get a cursor | |
| conn = sqlite3.connect(':memory:') | |
| c = conn.cursor() | |
| # create schema for a new table | |
| c.execute('CREATE TABLE IF NOT EXISTS sometable (name, age INTEGER)') | |
| conn.commit() |
| def inflate(d, sep="_"): | |
| items = dict() | |
| for k, v in d.items(): | |
| keys = k.split(sep) | |
| sub_items = items | |
| for ki in keys[:-1]: | |
| try: | |
| sub_items = sub_items[ki] | |
| except KeyError: |
| import pandas as pd | |
| from geopandas import GeoDataFrame | |
| from shapely.geometry import Point | |
| import fiona | |
| df = pd.read_csv('data.csv') | |
| geometry = [Point(xy) for xy in zip(df.x, df.y)] | |
| crs = {'init': 'epsg:2263'} #http://www.spatialreference.org/ref/epsg/2263/ | |
| geo_df = GeoDataFrame(df, crs=crs, geometry=geometry) |
| from io import BytesIO | |
| import gzip | |
| import shutil | |
| def upload_gzipped(bucket, key, fp, compressed_fp=None, content_type='text/plain'): | |
| """Compress and upload the contents from fp to S3. | |
| If compressed_fp is None, the compression is performed in memory. | |
| """ |
| # vim: set fileencoding=utf-8 : | |
| # | |
| # How to store and retrieve gzip-compressed objects in AWS S3 | |
| ########################################################################### | |
| # | |
| # Copyright 2015 Vince Veselosky and contributors | |
| # | |
| # Licensed under the Apache License, Version 2.0 (the "License"); | |
| # you may not use this file except in compliance with the License. | |
| # You may obtain a copy of the License at |
| """ | |
| """ | |
| import multiprocessing | |
| import boto | |
| import os | |
| import sys | |
| import datetime | |
| import logging | |
| import Queue |
| import asyncio | |
| import threading | |
| import random | |
| def thr(i): | |
| # we need to create a new loop for the thread, and set it as the 'default' | |
| # loop that will be returned by calls to asyncio.get_event_loop() from this | |
| # thread. | |
| loop = asyncio.new_event_loop() |