物联网消费者配置#

物联网使用者.Edit

概述#

创建适当的物联网消费者配置将使用户能够以直接、无缝的方式接收和分析适当的事件。物联网数据平台关键字的使用有助于此类配置，在配置物联网消费者时可以使用这些关键字。出于安全原因（例如数据库连接字符串）或为简单起见（例如Kafka主题名称），我们建议尽可能使用这些内容。启动物联网消费者后，系统会自动替换这些关键字。

系统关键字#

硬编码关键字，带有关于如何提取实际值的特定逻辑。有关详细信息，请参见下文。

Topic#

表示系统将为物联网事件定义推断的主题名称（主题是与Kafka代理技术相关的概念）。它遵循标准 systemname_eventtype_eventname_raw

示例： production_equipment_sensordata_raw

{
    "ReadSettings": {
        "Topic": "$(Topic)"
    },
}

TopicList#

表示主题列表，用逗号分隔。

示例： production_equipment_sensordata_raw, production_equipment_facilitydata_raw

{
    "ReadSettings": {
        "Topic": "$(TopicList)"
    },
}

EventDefinition#

表示物联网事件定义的名称

示例： “SensorData”

{
    "WriteSettings": {
        "TableName": "$(EventDefinition)"
    },
}

EventDefinitionList#

表示物联网事件定义列表，用逗号分隔

示例： “SensorData,FacilityData"

{
    "ReadSettings": {
        "InputEvents": "$(EventDefinitionList)"
    },
}

OnlineDBConnectionString#

使用只读帐户的MES联机数据库的连接字符串（采用JDBC格式）。

示例： MSINSTANCE\ONLINE;databaseName=AdventureWorks;user=MyUserName;password=*****;applicationName=IoTConsumerName;

{
    "ReadSettings": {
        "MetadataConnectionString": "$(OnlineDBConnectionString)",
    },
}

OnlineDBConnectionStringDotNet#

使用只读帐户的MES联机数据库的连接字符串（采用DotNet格式）。

示例： Data Source=MSINSTANCE\ONLINE;Initial Catalog= AdventureWorks;User ID= MyUserName;Password=*****;MultipleActiveResultSets=True

{
    "ReadSettings": {
        "MetadataConnectionString": "$(OnlineDBConnectionStringDotNet)",
    },
}

ControlTopic#

表示系统用于提交侦听器应用程序请求的特殊内部主题名称（例如消息总线接收器）。默认情况下，它应遵循标准 _systemname_dp.control

{
    "ControlTopic": "$(ControlTopic)"
}

MessageBusTopic#

表示系统用于提交要由消息总线发送的消息（例如实时数据用例）的特殊内部主题名称。默认情况下，它应遵循标准 _systemname_dp.messagebus

{
    "MessageBusTopic": "$(MessageBusTopic)"
}

可配置关键字#

在MES“配置”部分中的/Cmf/System/Configuration/IoTDataPlatform/分支下设置的所有值都将被递归提取并添加到键/值字典中。借助此机制，用户可以在配置中定义自定义关键字，并在物联网消费者定义中将其用作关键字。

此外，默认情况下，系统已经提供了许多条目，如下图所示，这些条目也可以用作关键字：

要在物联网消费者配置中引用可配置关键字，只需使用以下模板：$(keywordName).

示例用法：

{
    "ReadSettings": {
        "BootstrapServers": "$(KafkaBootstrapServers)",
        "SystemName": "$(SystemName)"
    },
    "WriteSettings": {
        "SparkURL" : "$(SparkEndpoint)"
    }
}