poros

lines = (for line in open("run/foo/access-log"))

# PYTHON 3 ONLY!!!
for i,line in enumerate(lines):
    print line
    if i == 10: lines.close()

poros

def trace(source):
    for item in source:
        print item
        yield item
        
r404 = trace(r for r in log if r['status'] == 404)

poros

class storelast(object):
    def __init__(self,source):
        self.source = source
    def next(self):
        item = self.source.next()
        self.last = item
        return item
    def __iter__(self):
        return self

poros

from job_class import Job

def delete_expired_stuff(time):
    print "Delete expired stuff before %s" % time

class CleanupJob(Job):
    # configuration: run at 5am
    run_at = '05:00'

    # implementation: nuke expired sessions

poros

from md5 import md5


class FakeHashRing(object):
    def __init__(self, nodes):
        self.nodes = list(nodes)

    def _hash(self, key):
        return int(md5(str(key).encode('utf-8')).hexdigest(), 16) % len(self.nodes)

poros

from collections import namedtuple
import re
import sys


SIGNALFX_API = 'https://app.signalfx.com/#/'
RES_TYPE_RE= re.compile(r"^(?P<type>\S+?)\..*:$")


# STATES