Skip to content

SDI nodes

Usage of SDI nodes

The following listing shows the Semantic Data Interconnect (SDI) nodes and their respective functions:

SDI create query

SDI create query

This node allows to create a query and retrieve the data. Query can be static or dynamic. The flow generates the output with a query ID and the data will be stored for further analysis.

SDI execution job

SDI execution job

This node allows to execute a job for the dynamic queries. The query ID generated from the sdi create query node should be mentioned in the node properties of the sdi execution job node. The flow generates the output with execution job ID and the data will be stored for further analysis.

SDI query results

SDI query results

This node shows the result for a query and it retrieves both static and dynamic data. The query ID and execution job ID should be mentioned in the node properties. The flow generates the output and the data will be stored for further analysis.

Note

If the flow is static, execution job ID is not required.

SDI ingest status

SDI ingest status

This node allows to get the status of the SDI ingest jobs. You can query the list of all ingest jobs or a single one.

Using SDI nodes

In order to use the SDI nodes with the integrated data lake (IDL), you have to do some preperation work. You cannot do that in VFC, but have to use the MindSphere APIs. The steps are:

  • Connect IDL to SDI (create a data lake record)
  • Create a data registry
  • Upload your data to IDL

Make sure that you upload the data in the "sdi" directory and add the meta-tag:

"registryid_{yourregistryid}"

If these requirements are fulfilled, SDI will be able to use the data.

See the SDI documentation for further details.

You can use these SDI nodes to create queries, execution jobs and execute queries.

Example scenario

Retrieve the dynamic data from the create queries, execution jobs and execute queries.

Objective

To retrieve the dynamic data from the create queries, execution jobs and execute queries and store it for further analysis.

SDI create query node procedure

To use SDI create query node, follow these steps:

  1. Select the "sdi create query" node from the "data Lake and sdi" palette.
  2. Connect the inject node with sdi create query node and debug node as shown below: timestamp my new query
  3. Double click the sdi create query node to edit the properties:
    • Name: My new query
    • Description: Creating a query
    • Dynamic: Yes
    • SQL Statement: SELECT airnow_aqi.parametername,airnow_aqi.reportingunits,airnow_aqi.value from airnow_aqi where airnow_aqi.sitename=:"airnow_aqi.sitename"
  4. Save and deploy.

SDI create query output

The output is displayed in the debug window:

SDI Create Query node output

SDI create query node output

① Query ID

SDI execution job node procedure

The SDI execution job is used to create dynamic queries only. For more information, see SDI execution job.

To use SDI execution job node, follow these steps:

  1. Select the "sdi execution job" node from the "data Lake and sdi" palette.
  2. Connect the inject node with sdi execution job node and debug node as shown below: timestamp execution
  3. Double click the sdi execution job node to edit the properties:
    • Name: execution job for WELLINGTON
    • Description: creating execution job
    • Query ID: 5ec3c9dc55e38921e78e1f66
    • Parameters: Name="airnow_aqi.sitename" and Value="WELLINGTON"
  4. Save and deploy.

SDI execution job output

The output is displayed in the message payload:

SDI execution job node output

SDI execution job node output

① Execution job ID

Note

Execution job node is only for dynamic queries.

SDI query results node procedure

To use SDI query results node, follow these steps:

  1. Select the "sdi query results" node from the "data Lake and sdi" palette.
  2. Connect the inject node with sdi query results node and debug node as shown below: timestamp sdi query
  3. Double click the sdi create query node to edit the properties:
    • Name: sdi query results
    • Query ID: 5ec3c9dc55e38921e78e1f66
    • Execution job ID: 5ec3ee5255e38921e78e1f79
  4. Save and deploy.

SDI query results

The output is displayed in the message payload:

SDI query result node output

SDI query result node output

SDI ingest status node procedure

The SDI ingest status node is used to get the status of the SDI ingest jobs. For more information, see SDI ingest status.

To use SDI query results node, follow these steps:

  1. Select the "sdi ingest status" node from the "data Lake and sdi" palette.
  2. Connect the inject node with sdi ingest status node and debug node as shown below: timestamp sdi ingest
  3. Save and deploy.

SDI ingest status output

The output is displayed in the message payload:

SDI ingest status node output

SDI ingest status node output

Any questions left?

Ask the community


Except where otherwise noted, content on this site is licensed under the MindSphere Development License Agreement.


Last update: April 27, 2022