| CPC H04L 51/212 (2022.05) [H04L 51/08 (2013.01); H04L 51/18 (2013.01); H04L 67/10 (2013.01); H04L 67/568 (2022.05)] | 16 Claims |
|
1. A computer-implemented method of subscribing to messages generated from a plurality of edge devices, comprising:
determining, at a cloud platform, whether a plurality of messages from a plurality of edge devices complies with a common schema indicative of a common information model to represent telemetry data associated with the plurality of edge devices;
receiving, at a cloud platform, the plurality of messages, wherein the plurality of messages complies with the common schema;
receiving, at the cloud platform from a custom application, one or more requests to generate at least one annotation stream and at least one annotation filter, wherein the annotation stream defines connection details of the annotation stream through which one or more subscribed messages to which the custom application is subscribed are delivered to a messaging end point, and wherein, the annotation filter defines filtering rules to be applied to the one or more subscribed messages that are to be delivered to the messaging end point as specified in the connection details of the annotation stream;
publishing, by the cloud platform, one or more of the plurality of messages to the at least one annotation stream based on the one or more annotation filters;
determining whether each of the one or more annotation filters is authorized based on the filtering rules defined in the respective annotation filter of the received request;
in response to determining that an annotation filter of the one or more annotation filters is authorized, associating the annotation filter with the at least one annotation stream; and
in response to determining that an annotation filter of the one or more annotation filters is not authorized, sending a notification to the custom application.
|