Getting Started: Processing Multi-Point Data¶

This guide intends to help you learn how to process data of multiple measuring points with the Multi-Point Aggregation template.

Prerequisites¶

Authorization to the Stream Data Processing module
Device connection is configured with data uploading to the cloud

Procedure¶

The procedure of processing data with the Multi-Point Merging template is as follows:

Design and create multiple point data processing job
Save and release the data processing job
Preview the data processing job with real-time data
Start the data processing job
Monitor the running status and results of the data processing job

Goal and Data Preparation¶

Goal

The goal of this guide is to get the sum of the raw data ingesting points testA_raw and testB_raw, and output the sum to point testC.

Data Preparation

Model configuration: Detailed information about the testModel used for this guide is as follows:

Feature Type	Name	Identifier	Point Type	Data Type
Measuring Point	testA_raw	testA_raw	AI	DOUBLE
Measuring Point	testB_raw	testB_raw	AI	DOUBLE
Measuring Point	testC	testC	AI	DOUBLE

Storage configuration: Configuring data storage policy for the 3 points (as either AI raw data or AI normalized data). For more information, see Configuring TSDB Storage.
Data ingestion: For information about data ingestion of input points testA_raw and testB_raw, see Device Connection.

Step 1. Develop a Multi-Point Data Processing Job¶

Log in EnOS Console and click Stream Data Processing > Stream Development to view all the data processing jobs created within the organization. You can double-click a job to view and edit its configuration.
Click the + icon above the job list to create a job. Enter the name and description of the job and select Multi-Point Merging as the template. Optionally, you can choose to import the configuration file of an existing job to complete the configuration quickly.
Triggering Mode: Select “point” as the triggering mode, and select “LastValue” as the timing interpolation strategy.
Data Processing: Click New Strategy and complete the following data processing strategy configuration:
- Output Point: Select the testC point to receive the output value of the data processing expression.
- Triggering Point: Select either testA_raw or testB_raw as the triggering point. If the data of testA_raw arrives later than that of testB_raw, select testA_raw as the triggering point. The system will trigger the output logic when the data of testA_raw arrives.
- Output Logic: Type data processing expression in the field and click Check Syntax to verify the expression. Enter the following expression for this guide:
```
${testModel::testA_raw}+${testModel::testB_raw}
```

Step 2. Save and Publish the Job¶

When the job configuration is completed, you can save and publish the multi point data processing job online. See the following sample configuration:

Step 3. Start the Job¶

On the Stream Operation page, find the published job in the table, and click the Start icon start_icon for the job in the Operations column to start running the data processing job.

Step 4. View the Running Results of the Job¶

On the Stream Operation page, find the running job in the table, and click the job name to open the Stream Details page. You can view the following information about the data processing job:

Summary: View the summary of the running job, such as the overall data processing records and the data aggregation records in a specific period.
Log: Click the View Logs icon on the upper right corner to check the running log of the job.
Results: Call the Get Asset Raw Data by Time Range API to get the data of point testC. For more information about data service API, go to EnOS Console > EnOS API.