如何区分Scorpio NGSI-LD中自服务发起的实体更新通知？

针对你遇到的无法区分Scorpio订阅通知是来自自身服务还是外部操作的问题，这里提供几个实用的解决思路：

1. 在更新请求中添加自定义标记属性 #

向Scorpio发送实体更新/创建请求时，为实体添加一个符合NGSI-LD规范的自定义属性（建议使用专属命名空间避免冲突），比如urn:myservice:source: "MyInternalService"。当Scorpio触发订阅通知时，这个属性会被包含在通知内容里：

• 收到通知后，检查实体是否带有该标记：如果有，说明是自身服务发起的操作，可直接跳过同步逻辑；如果没有，则判定为外部操作，执行同步。
• 若不想永久保留这个标记，可以在处理完通知后（或在更新实体时）额外发起请求移除该属性，或者在更新时通过@context定义该属性为临时属性（需Scorpio支持）。

2. 基于标记拆分订阅规则 #

调整你的Scorpio订阅策略，创建两个针对性的订阅：

• 第一个订阅：仅监听不包含自定义来源标记的实体变更（entityUpdate/entityCreated/entityDeleted），用于接收外部操作的通知，直接触发你的服务同步逻辑。
• 第二个订阅（可选）：专门监听包含自定义来源标记的变更，或者直接不创建这个订阅——因为自身服务发起的操作你已经知晓，无需再处理通知。
  这种方式利用Scorpio的订阅过滤能力，从源头就区分了不同来源的事件，减少后续处理逻辑。

3. 本地记录发起的操作日志 #

在自身服务向Scorpio发起更新/创建/删除请求时，本地记录关键信息：实体ID、操作类型（update/created/deleted）、发起时间戳。

• 当收到Scorpio的订阅通知时，先查询本地日志：如果是最近（比如5分钟内）自身发起的操作，则跳过同步；如果日志中无匹配记录，则判定为外部操作，执行同步。
• 注意设置日志的过期清理机制，避免存储冗余数据，同时考虑网络延迟导致的通知滞后，预留合理的时间窗口。

4. 利用请求追踪ID #

如果Scorpio支持请求元数据传递，在向Scorpio发起请求时，添加一个自定义请求头（比如X-Correlation-ID），并在本地记录这个ID。

• Scorpio的订阅通知可能会包含这个请求ID（部分NGSI-LD实现会在通知的notificationMetadata中携带），收到通知后匹配本地记录的ID，即可识别是否为自身发起的操作。

内容的提问来源于stack exchange，提问作者Sergio R.B.