You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 53 Next »

The ONC Python client library contains a number of classes and functions that make access to the ONC data, through the Oceans 2.0 API, quick and easy to use.

Requires

Image result for python logo

2.7 or Higher

3.6 or Higher Recommended

Installation

The ONC Python client library can be installed using the python pip module found in the Scripts folder of your python install.

$ pip install onc

 

If you have a previous version of the ONC Python Client Library installed, and need to get the latest version use the following:

$ pip install onc --upgrade

 

If you experience privileges issues while running pip, you can try running the pip module from the python executable, using the following:

$ python -m pip install onc

Opening the command prompt with 'Run As Administrator' may be required for some Windows installs.

Additional Python package install information can be found at https://packaging.python.org/tutorials/installing-packages/

 

Versions

versionDateDescriptionPackageSource
1.06/9/2017Beta versiononc-1.0.tar.gz 
1.16/12/2017Rename onc.dap.DAP class to onc.dap.ERDDAPonc-1.1.tar.gz 
1.116/13/2017

Removed unused numpy dependency.

Added python-dateutil dependency to package.

onc-1.11.tar.gz 
1.126/23/2017

Refactored scalar and raw data access methods.

Removed print methods for testing services.

Renamed private functions.

Added numpy references

onc-1.12.tar.gzonc-1.12-source.zip
1.137/31/2017Renamed getJsonFromUrl function to decodeJsonFromUrlonc-1.13.tar.gzonc-1.13-source.zip
1.148/01/2017Resolved issue with getDataProductUrls methodonc-1.14.tar.gzonc-1.14-source.zip
1.158/3/2017Updated production url from http://dmas.uvic.ca/ to http://data.oceannetworks.caonc-1.15.tar.gzonc-1.15-source.zip
1.168/11/2017Rename 'parameters' parameter to 'filters' in all applicable ONC class functionsonc-1.16.tar.gzonc-1.16-source.zip
1.178/15/2017Added file parameter defult to the download() function.onc-1.17.tar.gzonc-1.17-source.zip
1.188/23/2017

Added getDeployments() function.

Updated QA url from http://qaweb2.neptune.uvic.ca to https://qa.oceannetworks.ca

Updated production url to https

onc-1.18.tar.gzonc-1.18-source.zip

To download an attachment, please right click on the link and select Save Link AsSave Target As or a similar option provided by your browser. This will open a 'Save' dialog.

New versions are created to resolve known client library issues, add new functionality or handle changes to the underlying Web Services.

The latest version works with the current deployment of the underlying web services. See API Reference


Classes

classimportdescription
ONCfrom onc.onc import ONCA wrapper class for access to Oceans 2.0 API web services
SOSfrom onc.sos import SOSA wrapper class for access to ONC's implementation of Sensor Observation Service (SOS)
ERDDAPfrom onc.dap import ERDDAPA wrapper class for access to datasets published on ONC's ERDDAP (OPeNDAP) server http://qadap.onc.uvic.ca/erddap/index.html
NERCfrom onc.nerc import NERCA wrapper class for access to controlled vocabularies stored on the NERC vocabulary server http://vocab.nerc.ac.uk/


ONC Class

Description

This class provides a wrapper for some for the most common Oceans 2.0 API requests, including the discovery services (locations, devices, deviceCategories, properties) and delivery (dataProductDelivery, scalardata and rawdata).

Constructor

ONC()

ONC(token, production=True, showInfo=False, outPath='c:/temp')

Parameter
Type
Description
Example
Required   
tokenstringAll Web Services require a token. This can be generated at http://dmas.uvic.ca/Profile. Click on the "Web Services" tab and click "Generate Token"token=5ba514e8-1203-428c-8835-879c8173e387
Optional   
productionboolean

Indicates if the ONC Production server URL is used for service requests.

  • Default is True.
  • False is intended for internal ONC testing only.
  • All external users should use False or leave blank.
True or False
showInfoboolean

Indicates if verbose script messages are displayed, such as request url and processing time information.

  • Default is False.
  • True is intended for script debugging.
True or False
outPathstring

The path that downloaded files are saved to.

  • Default is 'c:/Temp'.
  • Full path will be created if it does not already exist.
'c:/ONC/Download'

 

Usage

from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

or

from onc.onc import ONC

isProduction = True
showInfo = False
outPath = 'c:/ONC/Data'
onc = ONC('YOUR_TOKEN_HERE',isProduction,showInfo,outPath)

 

Discovery methods

getLocations()

getLocations(filters={})


Returns a list of locations, as a list of dictionary objects that meet the criteria defined by the input filters.

 

Parameter
Type
Description
Example
Optional   
filtersdictionary

A dictionary of one or more filter criteria, used to return an exclusive set of location elements from the ONC locations endpoint.

{'locationCode':'BACAX'}


Returns

A list of location objects.

[
   {
      "deployments": 50,
      "locationName": "Axis ",
      "depth": 984.3076,
      "bbox": {
         "maxDepth": 987,
         "maxLat": 48.316837,
         "maxLon": -126.050125,
         "minDepth": 981,
         "minLat": 48.316517,
         "minLon": -126.05087
      },
      "description": "Depth: 985 m Latitude: 48.3167 Longitude: -126.0501 Type: Stationary platform Description: Canyon axis: benthic processes, biodiversity, sediment dynamics.",
      "hasDeviceData": "true",
      "lon": -126.05033,
      "locationCode": "BACAX",
      "hasPropertyData": "true",
      "lat": 48.31669,
      "dataSearchURL": "http://data.oceannetworks.ca/DataSearch?location=BACAX"
   }
]
Property
Type
Description
location[]listA list of location dictionaries

location[].deployments

intThe number of instrument deployments that meet the filter criteria
location[].locationNamestringThe full name of the location
location[].depthdoubleThe average depth of the deployments
location[].bboxdictionaryA Bounding Box dictionary
location[].bbox.maxDepthdoubleThe maximum depth of the deployments
location[].bbox.maxLatdoubleThe maximum Latitude of bounding box of the deployments
location[].bbox.maxLondoubleThe maximum Longitude of the bounding box of the deployments
location[].bbox.minDepthdoubleThe minimum Depth of the deployments
location[].bbox.minLatdoubleThe minimum Latitude of bounding box of the deployments
location[].bbox.minLondoubleThe minimum Longitude of the bounding box of the deployments
location[].descriptionstringThe description of the location
location[].hasDeviceDatastringIndicates that data products can be requrested using a device category for the location
location[].londoubleThe average longitude of the deployments
location[].locationCodestringA code that unquely identifies a location
location[].hasPropertyDatastringIndicates that data products can be requested using property code for the location
location[].latdoubleThe average latitude of the deployments
location[].dataSearchUrlstringThe location specific Data Search web page URL
Example - Print all locations in North East Pacific with Hydrophones deployed
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

locations = onc.getLocations({'locationCode':'NEP', 'deviceCategoryCode':'HYDROPHONE', 'includeChildren'='true'}) #NEP - North East Pacific
print('Locations')

for location in locations:
    locationCode = location['locationCode']
    locationName = location['locationName']
    hasDeviceData = location['hasDeviceData']
    hasPropertyData = location['hasPropertyData']
    if (len(locationCode.split('.')) == 2):
        parentName = onc.getLocationName(locationCode.split('.')[0])
        if (parentName):
            locationName = '{} / {}'.format(parentName,locationName)
    print('  {0} - {1}'.format(locationCode,locationName))
    print('     Request data product using Device Category (Site Device): {}'.format(hasDeviceData))
    print('     Request data product using Property (Primary Sensor): {}'.format(hasPropertyData))
print('{} locations'.format(len(locations)))

 

getDevices()

getDevices(filters={})

 

Returns a list of devices, as a list of dictionary objects that meet the criteria defined by the input filters.

 

Parameter
Type
Description
Example
Optional   
filtersdictionary

A dictionary of one or more filter criteria, used to return an exclusive set of device elements from the ONC devices endpoint.

{'deviceCode':'NORTEKADCP9917'}

 

Returns

A list of device objects

[
   {
      "cvTerm": {
         "device": [
            {
               "uri": "http://vocab.nerc.ac.uk/collection/L22/current/TOOL0888/",
               "vocabulary": "SeaVoX Device Catalogue"
            }
         ]
      },
      "dataRating": [
         {
            "dateFrom": "2008-11-01T00:00:00.000Z",
            "dateTo": "2010-05-27T19:27:04.000Z",
            "samplePeriod": 1,
            "sampleSize": 1
         },
         {
            "dateFrom": "2010-05-27T19:27:04.000Z",
            "dateTo": "None",
            "samplePeriod": 10,
            "sampleSize": 1
         }
      ],
      "deviceCode": "BC_POD1_AD2M",
      "deviceId": 11302,
      "deviceLink": "http://data.oceannetworks.ca/DeviceListing?DeviceId=11302",
      "deviceName": "Nortek Aquadopp HR-Profiler 2965"
   }
]
Property
Type
Description
device[]listA list of devices
device[].cvTermdictionaryA dictionary of controlled vocabulary terms
device[].cvTerm.device[]dictionaryA list of dictionaries of controlled vocabulary term information for the device
device[].cvTerm.device[].uristringThe Uri of the controlled vocabulary term
device[].cvTerm.device[].vocabularystringThe name of the controlled vocabulary that the term belongs to
device[].dataRating[]listA list of data ratings dictionaries
device[].dataRating[].dateFromdatetime string

The starting datetime for a data rating

device[].dataRating[].dateTodatetime string

The ending datetime for a data rating.

  • If None, the data rating was still in affect when the request was made
  • Date Time format: yyyy-MM-dd'T'HH:mm:ss.SSS'Z'
  • datetime is represented in Coordinated Universal Time (UTC) 

device[].dataRating[].samplePerioddoubleThe sample period, in seconds for the data rating
device[].dataRating[].sampleSizeintThe size of the data sample for the data rating
device[].deviceCodestringA code that unquely identifes a device
device[].deviceLinkstringThe Url link to the Devices Listing page for the specific device
device[].deviceNamestringThe name of the device
Example - Print all devices deployed at Barkley Canyon - Axis, between June 1, 2016 and May 31, 2017
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

devices = onc.getDevices({'locationCode':'BACAX','deploymentBegin':'2016-06-01T00:00:00.000Z','deploymentEnd':'2017-05-31T23:59:59.999Z'})  #BACAX - Barkley Canyon / Axis

print('Devices:')

for device in devices:
    deviceCode = device['deviceCode']
    deviceName = device['deviceName']
    print('  {} - {}'.format(deviceCode,deviceName))
print('{} devices'.format(len(devices)))

 

getDeployments()

getDeployments(filters={})

 

Returns a list of deployments, as a list of dictionary objects that meet the criteria defined by the input filters.

 

Parameter
Type
Description
Example
Optional   
filtersdictionary

A dictionary of one or more filter criteria, used to return an exclusive set of device elements from the ONC devices endpoint.

{'deviceCode':'NORTEKADCP9917'}

 

Returns

A list of deployment objects

[
   {
      "begin": "2016-06-14T08:58:41.000Z",
      "depth": 982,
      "deviceCode": "WLFLNTU1087",
      "end": "None",
      "hasDeviceData": true,
      "heading": "None",
      "lat": 48.31658,
      "locationCode": "BACAX",
      "lon": -126.0508,
      "pitch": "None",
      "roll": "None"
   },
   {
      "begin": "2016-06-14T06:05:24.000Z",
      "depth": 985,
      "deviceCode": "BC_POD1_ROTSONAR",
      "end": "None",
      "hasDeviceData": true,
      "heading": 90,
      "lat": 48.3166,
      "locationCode": "BACAX",
      "lon": -126.0508,
      "pitch": "None",
      "roll": "None"
   },
   {
      "begin": "2016-06-14T06:05:24.000Z",
      "depth": 985,
      "deviceCode": "NORTEKSIGNATURE550056",
      "end": "None",
      "hasDeviceData": true,
      "heading": 340,
      "lat": 48.3166,
      "locationCode": "BACAX",
      "lon": -126.0508,
      "pitch": "None",
      "roll": "None"
   },...
]



Property
Type
Description
Example
deployment[]   
deployment[].locationCodestringThe locationCode for the deployment location.
"locationCode":"BACAX"
deployment[].deviceCodestringThe deviceCode for a deployed device.
"deviceCode":"SBECTD19p6813"
deployment[].begindatetime

The beginning datetime of the deployment.

Date Time format: yyyy-MM-dd'T'HH:mm:ss.SSS'Z'

"begin":2010-07-27T00:00:00.000Z
deployment[].enddatetime

The ending datetime of the deployment.

  • If the deployment is current, the value is null.

Date Time format: yyyy-MM-dd'T'HH:mm:ss.SSS'Z'

"end":2016-08-01T00:00:00.000Z

deployment[].hasDeviceData

stringIndicates that data products can be requested using a device category code for the deployment.
"hasDeviceData":"true
deployment[].depthdoubleThe depth of the device deployment."depth":982
deployment[].latdouble

The latitude of the device deployment.

"lat":48.31658
deployment[].londoubleThe longitude of the device deployment."lon":-126.0508
deployment[].headingdoubleThe heading of the device deployment."heading":244
deployment[].pitchdoubleThe pitch of the device deployment."pitch":null
deployment[].rolldoubleThe pitch of the device deployment."roll":null
Example - Print all devices deployed at Barkley Canyon - Axis, between June 1, 2016 and May 31, 2017
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

deployments = onc.getDeployments({'locationCode':'BACAX','begin':'2016-06-01T00:00:00.000Z','end':'2017-05-31T23:59:59.999Z'})  #BACAX - Barkley Canyon / Axis

print('Deployments:')

for deployment in deployments:
	locationCode = deployment['locationCode']
    deviceCode = deployment['deviceCode']
    dtBegin = deployment['begin']
	etEnd = deployment['end']
    print('  {} - {} - {} to {}'.format(locationCode,deviceCode,dtBegin,dtEnd))
print('{} deployments'.format(len(deployments)))


getDeviceCategories()

getDeviceCategories(filters={})

 

Returns a list of deviceCategories, as a list of dictionary objects that meet the criteria defined by the input filters.

 

Parameter
Type
Description
Example
Optional   
filtersdictionary

A dictionary of one or more filter criteria, used to return an exclusive set of deviceCategory elements from the ONC deviceCategories endpoint.

{'deviceCategoryCode':'HYDROPHONE'}


Returns

A list of device category objects.

 [
   {
      "cvTerm": {
         "deviceCategory": [
            {
               "uri": "http://vocab.nerc.ac.uk/collection/L05/current/130/",
               "vocabulary": "SeaDataNet device categories"
            }
         ]
      },
      "description": "Conductivity Temperature (and Depth Sensor)",
      "deviceCategoryCode": "CTD",
      "deviceCategoryName": "CTD",
      "hasDeviceData": "true",
      "longDescription": " Conductivity Temperature Depth (CTD) is an abbreviated name for an instrument package that contains sensors for measuring the conductivity, temperature, and pressure of seawater. Salinity, sound velocity, and density are variables derived from sensor measurements. CTDs can carry additional instruments and sensors such as oxygen sensors, turbidity sensors and fluorometers. "
   }
]
Property
Type
Description
deviceCategory[]listA list of device categories
deviceCategory[].cvTermdictionaryA dictionary of controlled vocabulary terms
deviceCategory[].cvTerm.deviceCategory[]dictionaryA list of dictionaries of controlled vocabulary term information for the device category
deviceCategory[].cvTerm.deviceCategory[].uristringThe Uri of the controlled vocabulary term
deviceCategory[].cvTerm.deviceCategory[].vocabularystringThe name of the controlled vocabulary that the term belongs to
deviceCategory[].descriptionstringThe short description of the device category
deviceCategory[].deviceCategoryCodestringA code to uniquely identify a device category
deviceCategory[].deviceCategoryNamestringThe name of the device category
deviceCategory[].hasDeviceDatastringIndicates that data products can be requested using the device category for a location
deviceCategory[].longDescriptionstringThe long description of the device category
Example - Print all device categories available at Barkley Canyon - Upper Slope
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

deviceCategories = onc.getDeviceCategories({'locationCode':'NCBC'})    #NCBC - Barkely Canyon / Upper Slope

print('Device Categories:')

for deviceCategory in deviceCategories:
    deviceCategoryCode = deviceCategory['deviceCategoryCode']
    deviceCategoryName = deviceCategory['deviceCategoryName']
    print('  {} - {}'.format(deviceCategoryCode,deviceCategoryName))
print('{} device categories'.format(len(deviceCategories)))

 

getProperties()

getProperties(filters={})

 

Returns a list of properties, as a list of dictionary objects that meet the criteria defined by the input filters.

 

Parameter
Type
Description
Example
Optional   
filtersdictionary

A dictionary of one or more filter criteria, used to return an exclusive set of property elements from the ONC properties endpoint.

{'propertyCode':'seawatertemperature'}

 

Returns

A list of property objects.

 [
   {
      "cvTerm": {
         "property": [],
         "uom": [
            {
               "uri": "http://vocab.nerc.ac.uk/collection/P06/current/UPDB/",
               "vocabulary": "BODC data storage units"
            }
         ]
      },
      "description": "Pressure",
      "hasDeviceData": "true",
      "hasPropertyData": "true",
      "propertyCode": "pressure",
      "propertyName": "Pressure",
      "uom": "decibar"
   }
]
Property
Type
Description
property[]listA list of properties
property[].cvTermdictionaryA dictionary of controlled vocabulary terms
property[].cvTerm.property[]dictionaryA list of dictionaries of controlled vocabulary term information for the property
property[].cvTerm.property[].uristringThe Uri of the controlled vocabulary term
property[].cvTerm.property[].vocabularystringThe name of the controlled vocabulary that the term belongs to
property[].cvTerm.uom[]dictionaryA list of dictionaries of controlled vocabulary term information for the unit of measure
property[].cvTerm.uom[].uristringThe Uri of the controlled vocabulary term
property[].cvTerm.uom[].vocabularystringThe name of the controlled vocabulary that the term belongs to
property[].descriptionstringThe short description of the device category
property[].hasDeviceDatastringIndicates that data products can be requrested using the property code, along with a device category for a location
property[].hasPropertyDatastringIndicates that data products can be requested using the property code for a location
property[].propertyCodestringA code that uniquely identifies the property
property[].propertyNamestringThe name of the property
property[].uomstringThe Unit of Measure that the property measurements are in.
Example - Print all properties that are available at Barkley Canyon - Axis
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

properties = onc.getProperties({'locationCode':'BACAX'})  #BACAX - Barkley Canyon / Axis

print('Properties:')

for prprty in properties:
    propertyCode = prprty['propertyCode']
    propertyName = prprty['propertyName']
    description = prprty['description']
    print('  {} - {} ({})'.format(propertyCode,propertyName,description))
print('{} properties'.format(len(properties)))

 

getDataProducts()

getDataProducts(filters={})

 

Returns a list of data products as a list of dictionary objects that meet the criteria defined by the input filters.

 

Parameter
Type
Description
Example
Optional   
filtersdictionary

A dictionary of one or more filter criteria, used to return an exclusive set of dataProduct & extension elements from the ONC dataProducts endpoint.

{'dataProductCode':'TSSD','extension':'json'}

 

Returns

A list of data product objects.

[
   {
      "dataProductCode": "TSSD",
      "dataProductName": "Time Series Scalar Data",
      "extension": "json",
      "hasDeviceData": true,
      "hasPropertyData": true,
      "helpDocument": "https://wiki.oceannetworks.ca/display/DP/1"
   }
]
Property
Type
Description
dataProduct[]listA list of data products
dataProduct[].dataProductCodestringA code that uniquely identifies a data product
dataProduct[].dataProductNamestringThe name of the data product
dataProduct[].extensionstringThe extension for a data product
dataProduct[].hasDeviceDatastringIndicates that the data product can be requrested using a device category code and a location code
dataProduct[].hasPropertyDatastringIndicates that the data product can be requested using a property code and a location code or device code
Example - Print all MatLab data product
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

dataProducts = onc.getDataProducts({'extension':'mat'}) #mat - MatLab

print('Data Products:')

for c in sorted(set([str(dp['dataProductCode']) for dp in dataProducts])):
    name = [dp['dataProductName'] for dp in dataProducts if dp['dataProductCode'] == c][0]
    print ('{} - {}'.format(c,name))
    for e in sorted(set([dp['extension'] for dp in dataProducts if dp['dataProductCode'] == c])):
        print('  {}'.format(e))
print('{} data product extensions'.format(len(dataProducts))) 

 

Data Product Download methods

orderDataProduct()

orderDataProduct(filters={}, maxRetries=100, downloadResultsOnly=False, includeMetadataFile=True)

 

Requests a data product and downloads the generated files to the class's outPath.

This method performs the complete data product download workflow by calling additional methods to perform the following steps:

 1. Request a data product, which includes estimates for download size and time.

 2. Run a requested data product, which kicks off a process on the task machine to generate the data product.

 3. Download the data product to disk. The process will continue to poll the web service to determine if the product is ready to download. If it is not ready, status messages will be provided. Once it is ready, it will download the data product to disk

 

Parameter
Type
Description
Example
Required   
filtersdictionary

A dictionary of filter criteria parameters, used to request data as a data product from the ONC dataProductDelivery endpoint.

{'locationCode':'BACAX',
'deviceCategoryCode':'ADCP2MHZ',
'dataProductCode':'TSSD',
'extension':'csv',
'begin':'2016-07-27T00:00:00.000Z',
'end':'2016-08-01T00:00:00.000Z',
'dpo_qualityControl':1,
'dpo_resample':'none',
'dpo_dataGaps':0}

Option   
maxRetriesint

The number of times to retry the service before the function aborts.

  • If excluded, the default of 100 is used
10
downloadResultsOnlyboolean

Indicates if the files will be downloaded or if only the url to the file will be returned

  • False - Files are downloaded to the ONC class outPath property location
  • True - Files will not be downloaded. The download URLs are available from the url property for each downloadResult in downloadResults in the returned dictionary
  • If excluded, the default of False is used
True
includeMetadataFileboolean

Indicates if the metadata file associated with the data product request will be downloaded

  • False - Metadata file is not downloaded
  • True - Metadata file is downloaded
  • If excluded, the default of False is used.

True

 

Returns

A dictionary of download results and run time statistics.

{'downloadResults': [
    {
        'url': 'http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN>&dpRunId=<YOUR_RUN_ID>&index=1', 
        'message': [
            'Running', 
            'Transferring (BarkleyCanyon_Axis_ADCP2MHz_20160727T000005Z_20160731T235958Z-clean.csv) to the FTP server'
            ], 
        'queuingTime': 0, 
        'runningTime': 1.567234, 
        'transferringTime': 59.616635, 
        'downloadingTime': 0.295575, 
        'requestCount': 40, 
        'status': 'complete', 
        'size': 3060227.0, 
        'file': 'c:/ONC/data/BarkleyCanyon_Axis_ADCP2MHz_20160727T000005Z_20160731T235958Z-clean.csv', 
        'index': 1,
        'downloaded': True}, 
    {
        'url': 'http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN>&dpRunId=<YOUR_RUN_ID>&index=meta', 
        'message': [], 
        'queuingTime': 0, 
        'runningTime': 0, 
        'transferringTime': 0, 
        'downloadingTime': 0.132616, 
        'requestCount': 1, 
        'status': 'complete', 
        'size': 27502.0, 
        'file': 'c:/temp/doctest/BarkleyCanyon_Axis_ADCP2MHz_20160727T000005Z_20160731T235958Z-clean_CSV_META.pdf', 
        'index': 1, 
        'downloaded': True
    }
], 
'stats': {
    'requestRequestTime': 0.328399, 
    'runRequestTime': 1.060785, 
    'queuingTime': 0, 
    'runningTime': 1.567234, 
    'transferringTime': 59.616635, 
    'downloadingTime': 0.428191
    }
}
Property
Type
Description
downloadResultslistA list of download results dictionaries.
downloadResults[].urlstringThe URL used to make the download request.
downloadResults[].messagelistA list of the messages that were returned from the dataProductDelivery download method when it was polled.
downloadResults[].queuingTimefloatThe time duration, in seconds, between the first and last service request, that indicated that the task was queued.
downloadResults[].runningTimefloatThe time duration, in seconds, between the first request that returned a status message that it was running and the time that the request returned that it was transferring or complete.
downloadResults[].transferringTimefloatThe time duration, in seconds, between the first request that returned a status message that it was transferring.
downloadResults[].downloadingTimefloatThe time duration, in seconds, between the start and completion of the file download.
downloadResults[].requestCountintegerThe number of web service request that were made before the download was complete. This includes all of the requests that returned run task status messages.
downloadResults[].statusstring

The status of the download process at the request. Possible values are:

  • "running" - The data product request is running on the Task server.
  • "complete" - The data product request Task has completed and file has been downloaded or url has been returned.
  • "error" - An error, preventing the task execution or download from completing successfully, has occurred.
downloadResults[].sizefloatThe actual size of the file in bytes.
downloadResults[].filestringThe full path of the file that was downloaded.
downloadResults[].indexstringThe index of the file downloaded. The index can either be a number 1-* or "meta" for the data product metadata file.
downloadResults[].downloadedbooleanIndicates if the file was downloaded. If the filter downloadResultsOnly=True is used, the data product is not downloaded and the value will be False
statslistA summary of individual result statistics.
stats.requestRequestTimefloatThe time to complete the request request for the requested data product.
stats.runRequestTimefloatThe time to complete the run request for the requested data product.
stats.queuingTimefloatA sum of the queueTime times from all of the run requests for the requested data product.
stats.runningTimefloatA sum of the runningTime times from all of the run requests for the requested data product.
stats.transferringTimefloatA sum of the transferringTime times from all of the run requests for the requested data product.
stats.downloadingTimefloatA sum of the downloadTime times from all of the run requests for the requested data product.
Example - Download Time Series Scalar Data Product in CSV format for ADCP 2 MHZ at Barkley Canyon - Axis
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

results = onc.orderDataProduct({'locationCode':'BACAX',
		                        'deviceCategoryCode':'ADCP2MHZ',
        		                'dataProductCode':'TSSD',
                		        'extension':'csv',
                        		'begin':'2016-07-27T00:00:00.000Z',
                        		'end':'2016-08-01T00:00:00.000Z',
                        		'dpo_qualityControl':1,
                        		'dpo_resample':'none',
                        		'dpo_dataGaps':0})
print(results)

 

requestDataProduct()
requestDataProduct(filters={}, returnError=False)

 

Requests a data product using the dataProductDelivery service and provides request information so that the calling function can decide if should run the data product.
The dictionary of information it returns includes a requestID, which is used to run the data product, and estimates of the expected download times and file sizes.

 

Parameter
Type
Description
Example
Required   
filtersdictionary

A dictionary of filter criteria parameters, used to request data as a data product from the ONC dataProductDelivery endpoint.

{'locationCode':'BACAX',
'deviceCategoryCode':'ADCP2MHZ',
'dataProductCode':'TSSD',
'extension':'csv',
'begin':'2016-07-27T00:00:00.000Z',
'end':'2016-08-01T00:00:00.000Z',
'dpo_qualityControl':1,
'dpo_resample':'none',
'dpo_dataGaps':0}
Option   
returnErrorboolean

Indicates if error messages from the dataProductDelivery service should be returned.

  • True - error messages from the service call payload will be returned.
  • False - error messages will not be returned, but printed to console.
  • If excluded, the default value of False is used.
True

 

Returns

returns a data product request dictionary

for archived files (AD):

{
    "dpRequestId":2046404,
    "compressedFileSize":12563408,
    "fileSize":70766230,
    "numFiles":4,
    "downloadTimes":{"10Mbps":7.076623,"50Mbps":1.4153247,"150Mbps":0.47177488}
}

 

for generated files:

{
    "dpRequestId":2046404,
    "estimatedFileSize":8348187,
    "estimatedProcessingTime":16
}
Property
Type
Description
Example
Always contains
dpRequestIdintA unique id for a data product request
"dpRequestId":2046404
May contain
compressedFileSizeintThe compressed size of the known file(s) in bytes."compressedFileSize":12563408
fileSizeintThe size of known file(s) in bytes."fileSize":70766230
numFilesintThe number of files."numFiles":4
downloadTimesdictA dictionary of estimated download times"downloadTimes":{"10Mbps":7.076623,"50Mbps":1.4153247,"150Mbps":0.47177488}
estimatedFileSizeintThe estimated file size of generated data product"estimatedFileSize":8348187
estimatedProcessingTimeintThe estimated time, in seconds, that it will take to run the data product request."estimatedProcessingTime":16
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

 
requestInfo = onc.requestDataProduct({'locationCode':'BACAX',
			 						  'deviceCategoryCode':'ADCP2MHZ',
			 						  'dataProductCode':'TSSD',
			 						  'extension':'csv',
			 						  'begin':'2016-07-27T00:00:00.000Z',
			 						  'end':'2016-08-01T00:00:00.000Z',
			 						  'dpo_qualityControl':1,
			 						  'dpo_resample':'none',
			 						  'dpo_dataGaps':0})
print(requestInfo)

 

runDataProduct()
runDataProduct(requestId)

 

Runs a data product request using the dataProductDelivery service with a Request Id and returns a list of run ids

 

Parameter
Type
Description
Example
Required   
requestIdint

A dataProductDelivery dpRequestId, which is returned by the dataProductDelivery service request method, or as the 'dpRequestId' property in the dpRequest returned by the requestDataProduct() method.

2046404

 

Returns

a list of runIds

[ 
	4629218,
 	4629219
]
Example - Run a requested data product
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

ids = onc.runDataProduct(YOUR_REQUEST_ID_HERE)
 
print(ids)

 

downloadDataProduct()
downloadDataProduct(runId, fileCount=0, estimatedProcessingTime=1, maxRetries=100, downloadResultsOnly=False, includeMetadataFile=False, multiThreadMessages=False)

 

Polls the dataProductDelivery service until data product generation task is complete and downloads all of the files and/or retrieves the file information (url, file and download status).

 

Parameter
Type
Description
Example
Required   
runIdint

A dataProductDelivery dpRunId, which is returned by the dataProductDelivery service run method, or as the dpRunId property in the list returned by the runDataProduct() method.

4629218
Option   
fileCountint

The actual or estimated file count, which is returned from the dataProductDelivery request method

  • If there is no estimated file count, use 0.
  • If excluded, the default of 0 is used.
1
estimatedProcessingTimeint

The estimated time in seconds, that it should take to run the request on the task machine.

  • Used to determine how often the dataProductDelivery service is called to see if the task processing is complete.
  • Estimated processing time is provided by the dataProductDelivery request method
2
maxRetriesint

The number of times to retry the service before the function aborts.

  • If excluded, the default of 100 is used
10
downloadResultsOnlyboolean

Determines if the files will be downloaded or if only the url to the file will be returned

  • False - Files are downloaded to the ONC class outPath property location
  • True - Files will not be downloaded. The download URLs are available from the url property for each downloadResult in downloadResults in the returned dictionary
  • If excluded, the default of False is used
True
includeMetadataFileboolean

Indicates if the metadata file associated with the data product request will be downloaded

  • False - Metadata file is not downloaded
  • True - Metadata file is downloaded
  • If excluded, the default of False is used.

True

multiThreadMessagesboolean

Determines how the method and called method should print messages to the console. If downloading data products in a multi-threaded pattern, messages written to the console can overlap and progress dots can be written out of context

  • If excluded, the default of False is used.
True

 

Returns

returns a list of download results dictionaries

[
    {
        'url': 'http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN>&dpRunId=<YOUR_RUN_ID>&index=1', 
        'message': [
            'Running', 
            'Transferring (BarkleyCanyon_Axis_ADCP2MHz_20160727T000005Z_20160731T235958Z-clean.csv) to the FTP server'
            ], 
        'queuingTime': 0, 
        'runningTime': 1.567234, 
        'transferringTime': 59.616635, 
        'downloadingTime': 0.295575, 
        'requestCount': 40, 
        'status': 'complete', 
        'size': 3060227.0, 
        'file': 'c:/ONC/data/BarkleyCanyon_Axis_ADCP2MHz_20160727T000005Z_20160731T235958Z-clean.csv', 
        'index': 1,
        'downloaded': True}, 
    {
        'url': 'http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN>&dpRunId=<YOUR_RUN_ID>&index=meta', 
        'message': [], 
        'queuingTime': 0, 
        'runningTime': 0, 
        'transferringTime': 0, 
        'downloadingTime': 0.132616, 
        'requestCount': 1, 
        'status': 'complete', 
        'size': 27502.0, 
        'file': 'c:/temp/doctest/BarkleyCanyon_Axis_ADCP2MHz_20160727T000005Z_20160731T235958Z-clean_CSV_META.pdf', 
        'index': 'meta', 
        'downloaded': True
    }
]
Property
Type
Description
urlstringThe URL used to make the download request.
messagelistA list of the messages that were returned from the dataProductDelivery download method when it was polled.
queuingTimefloatThe time duration, in seconds, between the first and last service request, that indicated that the task was queued.
runningTimefloatThe time duration, in seconds, between the first request that returned a status message that it was running and the time that the request returned that it was transferring or complete.
transferringTimefloatThe time duration, in seconds, between the first request that returned a status message that it was transferring.
downloadingTimefloatThe time duration, in seconds, between the start and completion of the file download.
requestCountintegerThe number of web service request that were made before the download was complete. This includes all of the requests that returned run task status messages.
statusstring

The status of the download process at the request. Possible values are:

  • "running" - The data product request is running on the Task server.
  • "complete" - The data product request Task has completed and file has been downloaded or url has been returned.
  • "error" - An error, preventing the task execution or download from completing successfully, has occurred.
sizefloatThe actual size of the file in bytes.
filestringThe full path of the file that was downloaded.
indexstringThe index of the file downloaded. The index can either be a number 1-* or "meta" for the data product metadata file.
downloadedbooleanIndicates if the file was downloaded. If the filter downloadResultsOnly=True is used, the data product is not downloaded and the value will be False
Example - Download the results of requested data product run
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')

results = onc.downloadDataProduct(YOUR_RUN_ID_HERE, 1)
 
print(result)

 

getDataProdutUrls()

getDataProductUrls(filters, maxRetries=100)

 

Orders a data product and return only the urls, for download at a later time. Urls can be used with the downloadFile() or getJsonFromUrl() methods

 

Parameter
Type
Description
Example
Required   
filtersdictionary

A dictionary of filter criteria parameters, used to request data as a data product from the ONC dataProductDelivery endpoint.

{'locationCode':'BACAX',
'deviceCategoryCode':'ADCP2MHZ',
'dataProductCode':'TSSD',
'extension':'csv',
'begin':'2016-07-27T00:00:00.000Z',
'end':'2016-08-01T00:00:00.000Z',
'dpo_qualityControl':1,
'dpo_resample':'none',
'dpo_dataGaps':0}
Option   
maxRetriesint

The number of times to retry the service before the function aborts.

  • If excluded, the default of 100 is used
10

 

Returns

returns a list of urls

[
 'http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN>&dpRunId=<YOUR_RUN_ID>&index=1', 
 'http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN>&dpRunId=<YOUR_RUN_ID>&index=2'
]
Example - Order a data product and get a list of the download urls
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')
 
urls = onc.getDataProductUrls({'locationCode':'BACAX',
							   'deviceCategoryCode':'ADCP2MHZ',
                               'dataProductCode':'TSSD',
							   'extension':'json',
							   'begin':'2016-07-27T00:00:00.000Z',
							   'end':'2016-08-01T00:00:00.000Z',
							   'dpo_qualityControl':1,
							   'dpo_resample':'none',
							   'dpo_dataGaps':0,
							   'dpo_jsonOutputEncoding':'OM'},100)
 
print(urls)

 

downloadFile()

downloadFile(url, file, multiThreadMessages=False)

 

Downloads a file from a URL, write it to a file and return download results information (url, file, message and download status).

 

Parameter
Type
Description
Example
Required   
urlstring

The url to be downloaded

http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN_HERE>
&dpRunId=<YOUR_RUN_ID_HERE>&index=<YOUR_INDEX_HERE>
filestring

The full path of the file to be downloaded to.

  • If excluded, the file name from the content disposition in the header is used, along with the onc class object outPath to create a full file name path.
c:/temp/myDownload.csv
Option   
multiThreadMessagesboolean

Determines how the method and called method should print messages to the console. If downloading data products in a multi-threaded pattern, messages written to the console can overlap and progress dots can be written out of context

  • If excluded, the default of False is used.
True

 

returns a downloadResults dictionary

{
    'url': 'http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN>&dpRunId=<YOUR_RUN_ID>&index=1', 
    'file': 'c:/temp/myDownload.json', 
    'message': [], 
    'downloaded': True, 
    'downloadingTime': 0.641304
}
Property
Type
Description
urlstringThe URL used to make the download request.
filestringThe full path of the file that was downloaded.
messagelistA list of the messages that were returned from the dataProductDelivery download method when it was polled.
downloadedbooleanIndicates if the file was downloaded.
downloadingTimefloatThe time duration, in seconds, between the start and completion of the file download.
Example - Download a file from a url
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')
 
url = 'http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN_HERE>&dpRunId=<YOUR_RUN_ID_HERE>&index=<YOUR_INDEX_HERE>'
file = 'c:/temp/myDownload.csv'

downloadResult = onc.downloadFile(url, file)
 
print(downloadResult)

 

decodeJsonFromUrl()

decodeJsonFromUrl(url)

 

Returns a dictionary from the JSON returned from a URL

 

Parameter
Type
Description
Example
Required   
urlstring

The url to a JSON data product delivery result

http://data.oceannetworks.ca/api/dataProductDelivery?method=download&token=<YOUR_TOKEN_HERE>&dpRunId=<YOUR_RUN_ID_HERE>&index=<YOUR_INDEX_HERE>
Example - Get dictionary of results from json data product request
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')
 
urls = onc.getDataProductUrls({'locationCode':'BACAX',
							   'deviceCategoryCode':'ADCP2MHZ',
                               'dataProductCode':'TSSD',
							   'extension':'json',
							   'begin':'2016-07-27T00:00:00.000Z',
							   'end':'2016-08-01T00:00:00.000Z',
							   'dpo_qualityControl':1,
							   'dpo_resample':'none',
							   'dpo_dataGaps':0,
							   'dpo_jsonOutputEncoding':'OM'},100)
 
for url in urls:
	object = onc.decodeJsonFromUrl(url)
 	print(object)

 

Near Real-Time data product methods

getDirectScalar()

getDirectScalar(filters={}, outputFormat='Object', metadata='Full', rowLimit=None)

 

Returns scalar data, in JSON Object or Array format, in the response payload that meet the criteria defined by the input filters.

 

Parameter
Type
Description
Example
Required   
filtersdictionary

A dictionary of filter criteria parameters, used to request data and metadata from the ONC scalardata endpoint.

{
'locationCode':'TWDP',
'deviceCategoryCode':'TSG',
'begin':'2016-09-01T00:00:00.000Z',
'end':'2016-09-01T08:00:00.000Z'
}

Option   
outputFormatstring

The encoding of the response output.

  • Object - Data is a list of dictionaries with sampleTime, value and qaqcFlag for a given sensor.
  • Array - Data has 3 arrays for a given sensor. Array of sampleTime, array of values and array of qaqcFlags
  • If excluded, the default 'Object' is used.
"outputFormat":"Array"
metadatastring

The amount of metadata detail that is included in the response output.

  • Minimum - Provides only basic property information. Response includes serviceMetadata dictionary only.
  • Full - Provides all property information. Response includes both metadata and serviceMetadata dictionaries.
  • If excluded, the default 'Minimum' is used.
"metadata":"Full"
rowLimitinteger

The maximum number of rows of scalar data that will be returned for each sensor

  • Maximum is 100,000
  • If excluded, the default 100,000 is used
"rowLimit":5000

 

Returns

A dictionary that contains sensor data that matches the filter criteria defined in the input parameters, metadata and service metadata.

{
    'metadata': {
        'bbox': {
            'maxDepth': 3.0, 
            'maxLat': 49.080909946666665, 
            'maxLon': -123.37824890666667, 
            'minDepth': 3.0, 
            'minLat': 49.080909946666665, 
            'minLon': -123.37824890666667
        }, 
        'depth': 3.0, 
        'deviceCategoryName': 'TSG', 
        'latitude': 49.080909946666665, 
        'longitude': -123.37824890666667, 
        'begin': '2016-09-01T00:00:00.000Z', 
        'end': '2016-09-01T00:00:30.000Z', 
        'locationCode': 'TWDP'
    }, 
    'sensorData': [
        {
            'actualSamples': 1, 
            'data': [
                {
                    'qaqcFlag': 1, 
                    'sampleTime': '2016-09-01T00:00:07.037Z', 
                    'value': 3.44294
                }
             ], 
             'sensor': 'Conductivity', 
             'sensorName': 'Conductivity', 
             'unitOfMeasure': 'S/m'
        }, 
        {
            'actualSamples': 1, 
            'data': [
                {
                    'qaqcFlag': 1, 
                    'sampleTime': '2016-09-01T00:00:07.037Z', 
                    'value': 28.9096
                }
            ], 
            'sensor': 'salinity', 
            'sensorName': 'Practical Salinity', 
            'unitOfMeasure': 'psu'
        },
        {...}
    ], 
    'serviceMetadata': {
        'metadata': 'Full', 
        'nextDateFrom': '2016-09-01T00:00:17.041Z', 
        'outputFormat': 'Object', 
        'rowLimit': None, 
        'sensors': None, 
        'totalActualSamples': 3, 
        'begin': '2016-09-01T00:00:00.000Z', 
        'end': '2016-09-01T00:00:10.000Z', 
        'deviceCategoryCode': 'TSG', 
        'locationCode': 'TWDP'
    }
}
Property
Type
Description
metadatadictionaryA dictionary of metadata, if metadata='Full' input parameter is used
metadata.bboxdictionaryA Bounding Box dictionary
metadata.bbox.maxDepthfloatThe maximum depth of the instruments contributing to the results
metadata.bbox.maxLatfloatThe maximum Latitude of bounding box of the instruments contributing to the results
metadata.bbox.maxLonfloatThe maximum Longitude of the bounding box of the instruments contributing to the results
metadata.bbox.minDepthfloatThe minimum Depth of the instruments contributing to the results
metadata.bbox.minLatfloatThe minimum Latitude of bounding box of the instruments contributing to the results
metadata.bbox.minLonfloatThe minimum Longitude of the bounding box of the instruments contributing to the results
sensorDatalistA list of sensor dictionaries
sensorData[].acutalSamplesintThe number of samples in the data list
sensorData[].datalistA list of observation dictionaries
sensorData[].data[].qaqcFlagintThe QAQC Flag for the observation
sensorData[].data[].sampleTimedatetime string

The recorded time of the observation

sensorData[].data[].valuefloatThe value of the observation
sensorData[].sensorstringThe code of the sensor that is being observed
sensorData[].sensorNamestringThe name of the sensor that is being observed
sensorData[].unitOfMeasurestringThe unit of measure of the observation
serviceMetadatadictionaryA dictionary of the metadata for the service request
serviceMetadata.metadatastringThe requested metadata filter
serviceMetadata.nextDataFromdatetime stringThe begin date for next reading in yyyy-MM-ddTHH:mm:ss.SSSZ format
serviceMetadata.outputFormatstringThe requested JSON output format
serviceMetadata.rowLimitintThe requested row limit per sensor
serviceMetadata.sensorsstringA comma separated list of the requested sensors
serviceMetadata.totalActualSamplesintThe number of observations expected for all of the sensors
serviceMetadata.begindatetime stringThe begin date of the request in yyyy-MM-ddTHH:mm:ss.SSSZ format
serviceMetadata.enddatetime stringThe end date of the request in yyyy-MM-ddTHH:mm:ss.SSSZ format
serviceMetadata.deviceCategoryCodestringThe Device Category Code of the request. See Available Device Categories for further details
serviceMetadata.locationCodestringThe Location Code of the request. See Available Locations for further details.
Example - Print the last Thermosalinograph reading from Tswwassen - Duke Point Ferry
o = onc('YOUR_TOKEN_HERE')
 
result = o.getDirectScalar({'locationCode','TWDP','deviceCategoryCode','TSG'});

disp(result)
Example - Print 1 hour of Thermosalinograph readings from Tswwassen - Duke Point Ferry
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')
 
result = onc.getDirectScalar({'locationCode':'TWDP','deviceCategoryCode':'TSG', 'begin':'2016-09-01T00:00:00.000Z', 'begin':'2016-09-01T01:00:00.000Z'})

sensorData = result['sensorData']
if (sensorData):
	print('Properties (variables)')
	for data in sensorData:
		print("  {}".format(data['sensorName']))
		for sample in data['data']:
			print ("    Value = {} ; Sample Time = {}".format(sample['value'],sample['sampleTime']))
 
serviceMetadata = result['serviceMetadata']
if(serviceMetadata):
    print('{} samples'.format(serviceMetadata['totalActualSamples']))
Example - Print 1 hour of Thermosalinograph readings from Tswwassen - Duke Point Ferry as an Array
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')
 
result = onc.getDirectScalar({'locationCode':'TWDP','deviceCategoryCode':'TSG', 'begin':'2016-09-01T00:00:00.000Z', 'begin':'2016-09-01T01:00:00.000Z'},'Array')

if (result):
    sensorData = result['sensorData']
    if (sensorData):
        print('Properties (variables)')
        for data in sensorData:
            print("  {}".format(data['sensorName']))
            samples = data['data']
            for i in range(0,data['actualSamples'] - 1):
                print ("    Value = {} ; Sample Time = {}".format(samples['values'][i],samples['sampleTimes'][i]))
 
serviceMetadata = result['serviceMetadata']
if(serviceMetadata):
    print('{} samples'.format(serviceMetadata['totalActualSamples']))

 

getDirectRaw()

getDirectRaw(filters={}, rowLimit=None)

 

Returns raw data from an instrument in the payload, in JSON format that meet the criteria defined by the input filters.

 

Parameter
Type
Description
Example
Required   
filtersdictionary

A dictionary of filter criteria parameters, used to request data and metadata from the ONC rawdata endpoint.

{
'locationCode':'TWDP',
'deviceCategoryCode':'TSG',
'begin':'2016-09-01T00:00:00.000Z',
'end':'2016-09-01T08:00:00.000Z'
}

Option   
rowLimitinteger

The maximum number of rows of raw data that will be returned

  • Maximum is 100,000
  • If excluded, the default 100,000 is used
"rowLimit":5000

 

Returns

A dictionary that contains sensor data that matches the filter criteria defined in the input parameters, metadata and service metadata.

{
    'data': [
        {
            'rawData': '!AIVDM,1,1,,A,14eI18gP00G<JMPL<IaCNOv62D1C,0*43', 
            'sampleTime': '2017-06-23T17:18:04.645Z'
        }, 
        {
            'rawData': '!AIVDM,1,1,,A,34eGo=P009G;qPJL:kiv3I6800li,0*5C', 
            'sampleTime': '2017-06-23T17:18:04.698Z'
        }
    ], 
    'metadata': {
        'dataMetadata': {
            'firstTimestamp': '2017-06-23T17:18:04.645Z', 
            'hasMoreDataInRange': True, 
            'lastTimestamp': '2017-06-23T17:18:04.698Z', 
            'numberOfData': 2, 
            'locationCode': 'Iona Shore Station'
        }, 
        'queryMetadata': {
            'rowLimit': 2, 
            'stationCode': 'IONA', 
            'begin': None, 
            'end': None, 
            'deviceCategoryCode': 'AISRECEIVER'
        }
    }
}

 

 

Property
Type
Description
datadictionary 
data[].rawDatadictionaryA raw data string representing a sample at a specific time
data[].sampleTimedatetime string

The recorded time of the observation

metadatadictionaryA structure containing metadata
metadata.dataMetadatadictionaryA structure containing metadata about the data
metadata.dataMetadata.firstTimestampdatetime stringThe date time of the first record in yyyy-MM-ddTHH:mm:ss.SSSZ format
metadata.dataMetadata.hasMoreDataInRangeint

If the there is more data in the range of the request. For example if 1,000 records are returned (because the rowLimit=1000) but there should be 200,000 rows as defined by the filter criteria.

  • 0 = False
  • 1 = True
metadata.dataMetadata.lastTimestampdatetime stringThe date time of the last record in yyyy-MM-ddTHH:mm:ss.SSSZ format
metadata.dataMetadata.numberOfDataintThe number of samples in the data list
metadata.dataMetadata.locationNamestringThe full name of the location
metadata.queryMetadatastructA structure containing metadata about the data request (query)
metadata.queryMetadata.rowLimitintThe requested row limit per sensor
metadata.queryMetadata.begindatetime stringThe begin date of the request in yyyy-MM-ddTHH:mm:ss.SSSZ format
metadata.queryMetadata.enddatetime stringThe end date of the request in yyyy-MM-ddTHH:mm:ss.SSSZ format
metadata.queryMetadata.deviceCategoryCodestringThe Device Category Code of the request. See Available Device Categories for further details
metadata.queryMetadata.locationCodestringThe Location Code of the request. See Available Locations for further details.
Example - Print the last raw instrument reading from AIS Reviever at the Underwater Listening Station at IONA
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')
 
payload = onc.getDirectRaw({'locationCode':'IONA','deviceCategoryCode':'AISRECEIVER'},1)


data = payload['data']
if (data):
    for d in data:
        print ("  Raw Data = '{}' ; Sample Time = {}".format(d['rawData'],d['sampleTime']))


metadata = payload['metadata']
if(metadata):
    dataMetadata=metadata['dataMetadata']
    if(dataMetadata):
        print('{} samples'.format(dataMetadata['numberOfData']))
Example - Print 1 hour of raw CTD readings from Barkley Canyon Axis
from onc.onc import ONC
onc = ONC('YOUR_TOKEN_HERE')
 
payload = onc.getDirectRaw({'locationCode':'BACAX','deviceCategoryCode':'CTD','begin':'2017-05-23T00:00:00.000Z','end':'2017-05-23T01:00:00.000Z'})


data = payload['data']
if (data):
    for d in data:
        print ("  Raw Data = '{}' ; Sample Time = {}".format(d['rawData'],d['sampleTime']))


metadata = payload['metadata']
if(metadata):
    dataMetadata=metadata['dataMetadata']
    if(dataMetadata):
        print('{} samples'.format(dataMetadata['numberOfData']))

 

 

locationCode,

  • No labels