Version: 1.2.9
This sample uses Open Message Format to send real time data from a temperature sensor (or random sample values) to AVEVA Data Hub, Edge Data Store, and/or PI Web API. Once the sample is started, the sample periodically collects (or generates) values for temperature until it reaches a specified number of values. At each interval it then sends that data to each of the configured OMF endpoints.
- Clone the GitHub repository
- Install required modules:
pip install -r requirements.txt
- Open the folder with your favorite IDE
- Rename the placeholder config file appsettings.placeholder.json to appsettings.json
- Update appsettings.json with the credentials for the enpoint(s) you want to send to. See Configure endpoints and authentication below for additional details
- Run program.py
- Run test.py
- Install pytest
pip install pytest
- Run
pytest program.py
The sample is configured using the file appsettings.placeholder.json. Before editing, rename this file to appsettings.json
. This repository's .gitignore
rules should prevent the file from ever being checked in to any fork or branch, to ensure credentials are not compromised.
The application can be configured to send to any number of endpoints specified in the endpoints array within appsettings.json. In addition, there are three types of endpoints: ADH, EDS, and PI. Each of the 3 types of enpoints are configured differently and their configurations are explained in the sections below.
An OMF ingress client must be configured. On our OSIsoft Learning Channel on YouTube we have a video on Creating an OMF Connection.
The format of the configuration for an ADH endpoint is shown below along with descriptions of each parameter. Replace all parameters with appropriate values.
{
"Selected": true,
"EndpointType": "ADH",
"Resource": "https://uswe.datahub.connect.aveva.com",
"NamespaceId": "PLACEHOLDER_REPLACE_WITH_NAMESPACE_ID",
"Tenant": "PLACEHOLDER_REPLACE_WITH_TENANT_ID",
"clientId": "PLACEHOLDER_REPLACE_WITH_CLIENT_ID",
"ClientSecret": "PLACEHOLDER_REPLACE_WITH_CLIENT_SECRET",
"ApiVersion": "v1",
"VerifySSL": true,
"UseCompression": false,
"WebRequestTimeoutSeconds": 30
}
Parameters | Required | Type | Description |
---|---|---|---|
Selected | required | boolean | Tells the application if the endpoint should be sent to |
EndpointType | required | string | The endpoint type. For ADH this will always be "ADH" |
Resource | required | string | The endpoint for ADH if the namespace. If the tenant/namespace is located in NA, it is https://uswe.datahub.connect.aveva.com and if in EMEA, it is https://euno.datahub.connect.aveva.com |
NamespaceID | required | string | The name of the Namespace in ADH that is being sent to |
Tenant | required | string | The Tenant ID of the Tenant in ADH that is being sent to |
ClientId | required | string | The client ID that is being used for authenticating to ADH |
ClientSecret | required | string | The client secret that is being used for authenticating to ADH |
ApiVersion | required | string | The API version of the ADH endpoint |
VerifySSL | optional | boolean | A feature flag for verifying SSL when connecting to the ADH endpoint. By defualt this is set to true as it is strongly recommended that SSL be checked |
UseCompression | optional | boolean | A feature flag for enabling compression on messages sent to the ADH endpoint |
WebRequestTimeoutSeconds | optional | integer | A feature flag for changing how long it takes for a request to time out |
The format of the configuration for an EDS endpoint is shown below along with descriptions of each parameter. Replace all parameters with appropriate values.
{
"Selected": true,
"EndpointType": "EDS",
"Resource": "http://localhost:5590",
"ApiVersion": "v1",
"UseCompression": false
}
Parameters | Required | Type | Description |
---|---|---|---|
Selected | required | boolean | Tells the application if the endpoint should be sent to |
EndpointType | required | string | The endpoint type. For EDS this will always be "EDS" |
Resource | required | string | The endpoint for EDS if the namespace. If EDS is being run on your local machine with the default configuration, it will be http://localhost:5590 |
ApiVersion | required | string | The API version of the EDS endpoint |
UseCompression | optional | boolean | A feature flag for enabling compression on messages sent to the ADH endpoint |
WebRequestTimeoutSeconds | optional | integer | A feature flag for changing how long it takes for a request to time out |
The format of the configuration for a PI endpoint is shown below along with descriptions of each parameter. Replace all parameters with appropriate values.
{
"Selected": true,
"EndpointType": "PI",
"Resource": "PLACEHOLDER_REPLACE_WITH_PI_WEB_API_URL",
"DataArchiveName": "PLACEHOLDER_REPLACE_WITH_DATA_ARCHIVE_NAME",
"Username": "PLACEHOLDER_REPLACE_WITH_USERNAME",
"Password": "PLACEHOLDER_REPLACE_WITH_PASSWORD",
"VerifySSL": true,
"UseCompression": false
}
Parameters | Required | Type | Description |
---|---|---|---|
Selected | required | boolean | Tells the application if the endpoint should be sent to |
EndpointType | required | string | The endpoint type. For PI this will always be "PI" |
Resource | required | string | The URL of the PI Web API |
DataArchiveName | required | string | The name of the PI Data Archive that is being sent to |
Username | required | string | The username that is being used for authenticating to the PI Web API |
Password | required | string | The password that is being used for authenticating to the PI Web API |
VerifySSL | optional | boolean/string | A feature flag for verifying SSL when connecting to the PI Web API. Alternatively, this can specify the path to a .pem certificate file if a self-signed certificate is being used by the PI Web API. By defualt this is set to true as it is strongly recommended that SSL be checked. |
UseCompression | optional | boolean | A feature flag for enabling compression on messages sent to the ADH endpoint |
WebRequestTimeoutSeconds | optional | integer | A feature flag for changing how long it takes for a request to time out |
For the main OMF samples page ReadMe
For the main AVEVA samples page ReadMe