pyIUDX.rs package

Submodules

pyIUDX.rs.item module

class pyIUDX.rs.item.GeoProperty(name)

Bases: object

Container class for a Geo property GeoProperty is a spatial property having further attributes such as coordinates for either a point or a polygon.

name = None

Type in case geoProperty is static

reset()

Reset coordinates This is only invoked in case where this geoProperty is time varying TODO: Workaround for type

setDynamicGeo(time, coordinates)

Set Value for this geoProperty

To be used only when this geoProperty is time varying

Parameters:

• time (datetime.datetime()) – Time index
• value (float) – Value

setStaticGeo(geoProperty)

Static points

sort()

Sort time series

class pyIUDX.rs.item.Item(catUrl, resourceItemId, dataModel=None)

Bases: object

class for an iudx resource item

A resource item has it’s static attribute representation in a catalogue and a dynamic “data” representation in a resource server. This class presents an abstraction layer combining both

cat = None

get rs from catalogue item

Type:TODO

during(start, end)

Get data during a set interval for all properties belonging to this item

Parameters:

• startTime (string) – Start time
• endTime (string) – End time

Returns:

numpy 2d array with 0th column as time

Return type:

value (ndarray)

latest()

Get latest data for all properties belonging to this item

Returns:Returns back the updated object Return type:self (object)

latestWith(attr, val)

Get latest data for all properties belonging to this item with a specific attribute

This method will give latest data where an attribute is specified. For e.g attr = “ROUTE_ID”, val = “110” will give latest data for that bus

Parameters:

• attr (string) – The name of the attribute
• val (string) – The value of the attribute

Returns:

Returns back the updated object

Return type:

self (object)

populateValue(data)

Helper function to populate a QuantitativeProperty’s value array

quantitativeProperties = None

Load datamodel properties

reset()

Reset data of all quantitative attributes of this item :returns: Returns back the updated object :rtype: self (object)

timeProperty = None

Read item properties

valueBetween(attrName, minval, maxVal)

Get all data during which this attribute was between min and max val

Parameters:

• attrName (string) – name of the attribute
• minVal (int) – minimum value
• minVal – maximum value

class pyIUDX.rs.item.Items(catUrl, items=None)

Bases: collections.abc.MutableSequence

class for a list of iudx resource items.

This class extends a list to provide Class Item style functionality coupled with multiprocessing pool to allow for faster data access

during(startTime, endTime)

Get data during a set interval

For all resource items of this instance and for all properties belonging to this item

Parameters:

• startTime (string) – Start time
• endTime (string) – End time

Returns:

numpy 2d array with 0th column as time

Return type:

value (ndarray)

getDuring(obj, startTime, endTime)

Multiprocessed job

getLatest(obj)

Multiprocessed job

initItem(catUrl, item, objList)

Multiprocessed job

insert(ii, val)

S.insert(index, value) – insert value before index

latest()

Get latest data

For all resource items of this instance and for all properties belonging to this item

Returns:Returns back the updated object Return type:self (object)

class pyIUDX.rs.item.Property(name, properties)

Bases: object

Container class for a Property

Property is an aspect of a resource item that describes it or its current value

reset()

setValue(value, time=None)

Set State for this Property :param value: Value :type value: string :param time: Time index :type time: datetime.datetime()

sort()

Sort time series

class pyIUDX.rs.item.QuantitativeProperty(obj, name, properties)

Bases: object

Container class for a quantitative property QuantitativeProperty is a measureable property having further attributes such as units. Values are always indexed with time.

during(startTime, endTime)

Get data during a set interval for this property :param startTime: Start time :type startTime: string :param endTime: End time :type endTime: string

Returns:numpy 2d array with 0th column as time Return type:value (ndarray)

latest()

Get latest data for this property :returns: numpy 2d array with 0th column as time :rtype: value (ndarray)

reset()

Reset value of this Property

setValue(time, value)

Set Value for this Property :param time: Time index :type time: datetime.datetime() :param value: Value :type value: float

sort()

Sort time series

valueBetween(minval, maxVal)

Get all data during which this attribute was between min and max val :param minVal: minimum value :type minVal: int :param minVal: maximum value :type minVal: int

Returns:numpy 2d array with 0th column as time Return type:value (ndarray)

pyIUDX.rs.rs module

class pyIUDX.rs.rs.ResourceServer(rsUrl, cert=None, key=None)

Bases: object

dispParams()

Display rs initalization parameter

Returns:version string Return type:(rsDomain, rsPort, rsVersion) (string, string, string)

download(url, data)

Use requests library to make a search request

Returns:Response body Return type:resp (object)

downloadData(groupId, opts=None, token=None)

Download data from a resource server

An optional options dictionary can be passed to get more specific data. The options dictionary follows the schema: https://raw.githubusercontent.com/iudx/pyIUDX/rs/pyIUDX/rs/opts.json

Parameters:

• groupId (string) – id of the resource item
• opts (Dict) – dictionary of various options

Returns:

rs constructed url

Return type:

url (string)

getData(id, opts=None, token=None)

Get data from a resource server

An optional options dictionary can be passed to get more specific data. The options dictionary follows the schema: https://raw.githubusercontent.com/iudx/pyIUDX/rs/pyIUDX/rs/opts.json

Parameters:

• id (string) – id of the resource item
• opts (Dict) – dictionary of various options

Returns:

rs constructed url

Return type:

url (string)

getDataAfter(id, time, token=None)

Get data after a given time

Parameters:

• id (string) – id of the resource item
• time (string) – Starting from

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getDataAroundDuring(id, point, radius, startTime, endTime, token=None)

Get data around a specific point(lat, lon) and radius(meters) and during a time

Parameters:

• id (string) – id of the resource item
• point (List[Float]) – point [lat, lon]
• radius (int) – radius in meters
• startTime (string) – Starting from
• endTime (string) – Till

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getDataBefore(id, time, token=None)

Get data before a given time

Parameters:

• id (string) – id of the resource item
• time (string) – Ending at

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getDataDuring(id, startTime, endTime, token=None)

Get data during a time interval

Parameters:

• id (string) – id of the resource item
• startTime (string) – Starting from
• endTime (string) – Till

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getDataValuesBetween(id, attribute, minVal, maxVal, token=None)

Get data of an item for which an attribute is between minVal and maxVal

Parameters:

• id (string) – id of the resource item
• attribute (string) – attribute name
• minVal (float) – minimum value
• maxVal (float) – maximum value

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getDataValuesGreater(id, attribute, minVal, token=None)

Get data of an item for which an attribute is greater than minVal

Parameters:

• id (string) – id of the resource item
• attribute (string) – attribute name
• minVal (float) – minimum value

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getDataValuesLesser(id, attribute, maxVal, token=None)

Get data of an item for which an attribute is lesser than maxVal

Parameters:

• id (string) – id of the resource item
• attribute (string) – attribute name
• maxVal (float) – maximum value

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getDataValuesLikeDuring(id, attribute, val, startTime, endTime, token=None)

Get data of an item for which an attribute is like value between a time

Parameters:

• id (string) – id of the resource item
• attribute (string) – attribute name
• val (string) – value

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getLatestData(id, token=None)

Get latest data

Parameters:id (string) – id of the resource item Returns:

Array with a single dictionary

item corresponding to the data

Return type:data (List[Dict])

getLatestDataAround(id, point, radius, token=None)

Get data around a specific point(lat, lon) and radius(meters)

Parameters:

• id (string) – id of the resource item
• point (List[Float]) – point [lat, lon]
• radius (int) – radius in meters

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getLatestDataAroundLike(id, point, radius, attributeName, attributeValue, token=None)

Get data around a specific point(lat, lon) and radius(meters) which has an attribute like

Parameters:

• id (string) – id of the resource item
• point (List[Float]) – point [lat, lon]
• radius (int) – radius in meters

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getLatestDataValuesLike(id, attribute, val, token=None)

Get latest data of an item for which an attribute is like value

Parameters:

• id (string) – id of the resource item
• attribute (string) – attribute name
• val (string) – value

Returns:

Array with a time indexed dictionary

item corresponding to the data

Return type:

data (List[Dict])

getStatus(id, token=None)

Get Status of a resource item

Parameters:id (string) – id of the resource item Returns:True if up Return type:status (bool)

TODO:

getUrl()

Get rs constructed url

Returns:rs constructed url Return type:url (string)

search(url, data)

Use requests library to make a search request

Returns:Response body Return type:resp (object)

Module contents