app.py 文件源码

def GET( self ):
        params = web.input( ip = None )

        if params.ip is None:
            raise web.HTTPError( '400 Bad Request: ip required' )

        usage = querySites( 'models', 'get_ip_usage', 
                            queryData = { 'ip' : params.ip, 'oid' : getOrgs().keys() },
                            siteProc = lambda res, ctx, site: res[ 'usage' ], 
                            qProc = lambda res, ctx: [ x for x in itertools.chain( res ) ] )
        return usage

# This is a waterhose feed from a single sensor, it streams traffic as json.