connectordb/_stream.py
def query_maker(t1=None, t2=None, limit=None, i1=None, i2=None, transform=None, downlink=False):
    """query_maker takes the optional arguments and constructs a json query for a stream's
    datapoints using it::
        #{"t1": 5, "transform": "if $ > 5"}
        print query_maker(t1=5,transform="if $ > 5")
    """
    params = {}
    if t1 is not None:
        params["t1"] = t1
    if t2 is not None:
        params["t2"] = t2
    if limit is not None:
        params["limit"] = limit
    if i1 is not None or i2 is not None:
        if len(params) > 0:
            raise AssertionError(
                "Stream cannot be accessed both by index and by timestamp at the same time.")
        if i1 is not None:
            params["i1"] = i1
        if i2 is not None:
            params["i2"] = i2

    # If no range is given, query whole stream
    if len(params) == 0:
        params["i1"] = 0
        params["i2"] = 0

    if transform is not None:
        params["transform"] = transform
    if downlink:
        params["downlink"] = True

    return params
def query_maker(t1=None, t2=None, limit=None, i1=None, i2=None, transform=None, downlink=False):
    """query_maker takes the optional arguments and constructs a json query for a stream's
    datapoints using it::
        #{"t1": 5, "transform": "if $ > 5"}
        print query_maker(t1=5,transform="if $ > 5")
    """
    params = {}
    if t1 is not None:
        params["t1"] = t1
    if t2 is not None:
        params["t2"] = t2
    if limit is not None:
        params["limit"] = limit
    if i1 is not None or i2 is not None:
        if len(params) > 0:
            raise AssertionError(
                "Stream cannot be accessed both by index and by timestamp at the same time.")
        if i1 is not None:
            params["i1"] = i1
        if i2 is not None:
            params["i2"] = i2

    # If no range is given, query whole stream
    if len(params) == 0:
        params["i1"] = 0
        params["i2"] = 0

    if transform is not None:
        params["transform"] = transform
    if downlink:
        params["downlink"] = True

    return params
def query_maker ( t1 = None , t2 = None , limit = None , i1 = None , i2 = None , transform = None , downlink = False ) : params = { } if t1 is not None : params [ "t1" ] = t1 if t2 is not None : params [ "t2" ] = t2 if limit is not None : params [ "limit" ] = limit if i1 is not None or i2 is not None : if len ( params ) > 0 : raise AssertionError ( "Stream cannot be accessed both by index and by timestamp at the same time." ) if i1 is not None : params [ "i1" ] = i1 if i2 is not None : params [ "i2" ] = i2 # If no range is given, query whole stream if len ( params ) == 0 : params [ "i1" ] = 0 params [ "i2" ] = 0 if transform is not None : params [ "transform" ] = transform if downlink : params [ "downlink" ] = True return params
query_maker takes the optional arguments and constructs a json query for a stream's
    datapoints using it::
        #{"t1": 5, "transform": "if $ > 5"}
        print query_maker(t1=5,transform="if $ > 5")
query_maker takes the optional arguments and constructs a json query for a stream s datapoints using it :: # { t1 : 5 transform : if $ > 5 } print query_maker ( t1 = 5 transform = if $ > 5 )