基本配置

标准制造数据引擎 (MDE) 部署默认情况下不会应用任何开始提取数据所需的配置设置。

本指南将引导您完成基本的 MDE 设置。例如，用于测试系统是否能正常运行。借助本指南，您可以为所有三种原型创建消息类、类型和解析器。

如果您打算使用 Manufacturing Connect Edge (MCe) 来注入数据，请改为部署默认配置软件包。

您可以使用 MDE API 或网页界面来完成此配置。

注意：如需使用该 API，您应预先配置 通过 IAP 进行 SSH 隧道传输。

警告：此配置不适用于生产使用情形。请务必根据具体使用场景调整配置。

消息类

本部分提供了 MDE 中可用的消息类示例。

重要提示： 自 MDE 版本 1.4.1 起，消息标头存储在名为 mdeHeaders 的预留属性中。使用 #root.headers['SOME_ATTRIBUTE'] 等表达式的现有 message-class 在弃用之前，在未来几个版本中仍可继续使用。请务必更新您的消息类表达式，以改用 #root.mdeHeaders['SOME_ATTRIBUTE']。

numeric 的消息类

以下是 basic-numeric 消息类的一个示例：

REST

POST /configuration/v1/message-classes

{
   "name": "basic-numeric",
   "priority": 2000,
   "expression": "#root.event['value'] instanceof T(Number) && #root.event['timestamp'] != null && #root.event['tagName'] != null"
}

网页界面

消息类名称：basic-numeric

1. 在 MDE 网页界面中，点击消息类。
2. 点击 Add new Message Class。
3. 将 Message Class name 填写为 basic-numeric。

4. 复制以下表达式并将其粘贴到表达式框中：

      #root.event['value'] instanceof T(Number) && #root.event['timestamp'] != null && #root.event['tagName'] != null
   

5. 将优先级更改为 2000。

6. 点击创建。

   

discrete 的消息类

以下是 basic-discrete 消息类的一个示例：

REST

POST /configuration/v1/message-classes

   {
      "name": "basic-discrete",
      "priority": 1975,
      "expression": "#root.event['value'] != null && !(#root.event['value'] instanceof T(Number)) && #root.event['timestamp'] != null && #root.event['tagName'] != null"
   }

网页界面

消息类名称：basic-discrete

1. 在 MDE 网页界面中，点击消息类。
2. 点击 Add new Message Class。
3. 将 Message Class name 填写为 basic-discrete。

4. 复制以下表达式并将其粘贴到表达式框中：

      #root.event['value'] != null && !(#root.event['value'] instanceof T(Number)) && #root.event['timestamp'] != null  && #root.event['tagName'] != null
   

5. 将优先级更改为 1975。

6. 点击创建。

   

continuous 的消息类

以下是 basic-continuous 消息类的一个示例：

REST

POST /configuration/v1/message-classes

   {
      "name": "basic-continuous",
      "priority": 1950,
      "expression": "#root.event['value'] != null && !(#root.event['value'] instanceof T(Number)) && #root.event['startTimestamp'] != null && #root.event['endTimestamp'] != null && #root.event['tagName'] != null"
   }

网页界面

消息类名称：basic-continuous

1. 在 MDE 网页界面中，点击消息类。
2. 点击 Add new Message Class。
3. 将 Message Class name 填写为 basic-continuous。

4. 复制以下表达式并将其粘贴到表达式框中：

   #root.event['value'] != null && !(#root.event['value'] instanceof T(Number)) && #root.event['startTimestamp'] != null && #root.event['endTimestamp'] != null && #root.event['tagName'] != null
   

5. 将优先级更改为 1950。

6. 点击创建。

   

类型

本部分简要介绍了 MDE 中可用的类型。

重要提示： 创建类型时，请务必等待类型完全完成配置并激活，然后再创建解析器。此过程最多可能需要 2-3 分钟。

numeric 的类型

以下是 basic-numeric 类型的一个示例：

REST

POST /configuration/v1/types

{
   "archetype": "NUMERIC_DATA_SERIES",
   "name": "basic-numeric"
}

网页界面

名称：basic-numeric

1. 在 MDE 网页界面上，点击类型。
2. 点击添加新类型。
3. 将类型名称填写为 basic-numeric。

4. 在原型的下拉菜单中，选择 NUMERIC_DATA_SERIES：

   

5. 打开存储空间设置部分。

6. 切换发送到 BigQuery 选项。

7. 点击创建。

discrete 的类型

以下是 basic-discrete 类型的一个示例：

REST

POST /configuration/v1/types

{
   "archetype": "DISCRETE_DATA_SERIES",
   "name": "basic-discrete"
}

网页界面

名称：basic-discrete

1. 在 MDE 网页界面上，点击类型。
2. 点击添加新类型。
3. 将类型名称填写为 basic-discrete。

4. 在原型的下拉菜单中选择 DISCRETE_DATA_SERIES：

   

5. 打开存储空间设置部分。

6. 切换发送到 BigQuery 选项。

7. 点击创建。

continuous 的类型

以下是 basic-continuous 类型的一个示例：

REST

POST /configuration/v1/types

{
   "archetype": "CONTINUOUS_DATA_SERIES",
   "name": "basic-continuous"
}

网页界面

名称：basic-continuous

1. 在 MDE 网页界面上，点击类型。
2. 点击添加新类型。
3. 将类型名称填写为 basic-continuous。

4. 在原型的下拉菜单中选择 CONTINUOUS_DATA_SERIES：

   

5. 打开存储空间设置部分。

6. 切换发送到 BigQuery 选项。

7. 点击创建。

解析器

本部分简要介绍了 MDE 中提供的各种解析器。在创建解析器之前，请确保类型已完全配置并处于 active 状态。此过程最多可能需要三分钟。

重要提示： 自 MDE 版本 1.4.1 起，消息头现在存储在名为 mdeHeaders 的预留属性中。如果输入消息包含该属性，则类似 embeddedMetadata: $root[where ($.field !=...)] 的表达式会覆盖预留属性，导致随边缘消息提供的标头数据丢失。请务必谨慎使用通用 Whistle 过滤条件表达式，以免导致数据丢失。

numeric 的解析器

以下是 basic-numeric 解析器的示例：

REST

POST /configuration/v1/parsers

{
   "name": "basic-numeric-to-basic-numeric",
   "messageClassName": "basic-numeric",
   "typeReference": {
         "name": "basic-numeric",
         "version": 1
   },
   "script": "package mde\n\n[{\ntagName: $root.tagName;\ntimestamps: MapTimestamp($root);\ndata: MapData($root);\nembeddedMetadata: $root[where ($.field != \"value\" and $.field != \"tagName\" and $.field != \"timestamp\" and $.field != \"messageId\")];\n}]\n\ndef MapTimestamp(input) {\n    eventTimestamp: input.timestamp;\n}\n\ndef MapData(input) {\n    numeric: input.value;\n}"
}

网页界面

名称：basic-numeric-to-basic-numeric

1. 在 MDE 网页界面中，点击 解析器。
2. 点击添加新解析器。
3. 将 Parser name 填写为 basic-numeric-to-basic-numeric。
4. 在消息类名称的下拉菜单中，选择 basic-numeric。

5. 将以下 Whistle 代码复制并粘贴到 Parser 框中：

    package mde
   
    [{
    tagName: $root.tagName;
    timestamps: MapTimestamp($root);
    data: MapData($root);
    embeddedMetadata: $root[where ($.field != "value" and $.field != "tagName" and $.field != "timestamp" and $.field != "messageId")];
    }]
   
    def MapTimestamp(input) {
       eventTimestamp: input.timestamp;
    }
   
    def MapData(input) {
       numeric: input.value;
    }
   

6. 在类型下拉菜单中，选择 basic-numeric | version: 1。

7. 点击创建。

   

discrete 的解析器

以下是 basic-discrete 解析器的示例：

REST

POST /configuration/v1/parsers

{
   "name": "basic-discrete-to-basic-discrete",
   "messageClassName": "basic-discrete",
   "typeReference": {
         "name": "basic-discrete",
         "version": 1
   },
   "script": "package mde\n\n[{\ntagName: $root.tagName;\ntimestamps: MapTimestamp($root);\ndata: MapData($root);\nembeddedMetadata: $root[where ($.field != \"value\" and $.field != \"tagName\" and $.field != \"timestamp\" and $.field != \"messageId\")];\n}]\n\ndef MapTimestamp(input) {\n    eventTimestamp: input.timestamp;\n}\n\ndef MapData(input) {\n    complex: input.value;\n}\n"
}

网页界面

名称：basic-discrete-to-basic-discrete

1. 在 MDE 网页界面中，点击 解析器。
2. 点击添加新解析器。
3. 将 Parser name 填写为 basic-numeric-to-basic-discrete。
4. 在消息类名称的下拉菜单中，选择 basic-discrete。

5. 将以下 Whistle 代码复制并粘贴到 Parser 框中：

    package mde
   
    [{
    tagName: $root.tagName;
    timestamps: MapTimestamp($root);
    data: MapData($root);
    embeddedMetadata: $root[where ($.field != "value" and $.field != "tagName" and $.field != "timestamp" and $.field != "messageId")];
    }]
   
    def MapTimestamp(input) {
       eventTimestamp: input.timestamp;
    }
   
    def MapData(input) {
       complex: input.value;
    }
   

6. 在类型下拉菜单中，选择 basic-discrete | version: 1。

7. 点击创建。

   

continuous 的解析器

以下是 basic-continuous 解析器的示例：

REST

POST /configuration/v1/parsers

{
   "name": "basic-continuous-to-basic-continuous",
   "messageClassName": "basic-continuous",
   "typeReference": {
         "name": "basic-continuous",
         "version": 1
   },
   "script": "package mde\n\n[{\ntagName: $root.tagName;\ntimestamps: MapTimestamp($root);\ndata: MapData($root);\nduration: $root.duration;\nembeddedMetadata: $root[where ($.field != \"value\" and $.field != \"tagName\" and $.field != \"startTimestamp\" and $.field != \"endTimestamp\" and $.field != \"messageId\")];\n}]\n\ndef MapTimestamp(input) {\n    continuousTimestamp: {\n        eventTimestampStart: input.startTimestamp;\n        eventTimestampEnd: input.endTimestamp;\n    };\n}\n\ndef MapData(input) {\n    complex: input.value;\n}\n"
}

网页界面

名称：basic-continuous-to-basic-continuous

1. 在 MDE 网页界面中，点击 解析器。
2. 点击添加新解析器。
3. 将 Parser name 填写为 basic-numeric-to-basic-continuous。
4. 在消息类名称的下拉菜单中，选择 basic-continuous。

5. 将以下 Whistle 代码复制并粘贴到 Parser 框中：

    package mde
   
    [{
    tagName: $root.tagName;
    timestamps: MapTimestamp($root);
    data: MapData($root);
    duration: $root.duration;
    embeddedMetadata: $root[where ($.field != "value" and $.field != "tagName" and $.field != "startTimestamp" and $.field != "endTimestamp" and $.field != "messageId")];
    }]
   
    def MapTimestamp(input) {
       continuousTimestamp: {
          eventTimestampStart: input.startTimestamp;
          eventTimestampEnd: input.endTimestamp;
       };
    }
   
    def MapData(input) {
       complex: input.value;
    }
   

6. 在类型下拉菜单中，选择 basic-continuous | version: 1。

7. 点击创建。