Rule-based annotation service in a cloud platform

A system for subscribing to messages generated from a plurality of edge devices, comprising:

• one or more processors;
• and
• a non-transitory computer readable medium storing instructions that, when executed by the one or more processors, cause the one or more processors to perform a method 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.

A non-transitory computer readable medium storing instructions that, when executed by one or more processors, cause the one or more processors to perform a 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.