US 11,789,942 B2
Dynamic asset monitoring and management using a continuous event processing platform
Roman Schindlauer, Seattle, WA (US); Balan Sethu Raman, Redmond, WA (US); Torsten W. Grabs, Seattle, WA (US); and Beysim Sezgin, Redmond, WA (US)
Assigned to Microsoft Technology Licensing, LLC, Redmond, WA (US)
Filed by Microsoft Technology Licensing, LLC, Redmond, WA (US)
Filed on Jan. 20, 2022, as Appl. No. 17/579,603.
Application 17/579,603 is a continuation of application No. 16/548,515, filed on Aug. 22, 2019, granted, now 11,243,946.
Application 16/548,515 is a continuation of application No. 14/636,437, filed on Mar. 3, 2015, granted, now 10,409,809, issued on Sep. 10, 2019.
Application 14/636,437 is a continuation of application No. 12/826,689, filed on Jun. 30, 2010, granted, now 8,977,643, issued on Mar. 10, 2015.
Prior Publication US 2022/0147518 A1, May 12, 2022
Int. Cl. G06F 16/245 (2019.01); G06F 16/25 (2019.01); G06F 16/2455 (2019.01); G06F 16/2458 (2019.01); G06F 16/22 (2019.01); G06F 16/242 (2019.01)
CPC G06F 16/245 (2019.01) [G06F 16/24568 (2019.01); G06F 16/258 (2019.01); G06F 16/22 (2019.01); G06F 16/2255 (2019.01); G06F 16/2428 (2019.01); G06F 16/2471 (2019.01)] 20 Claims
OG exemplary drawing
 
1. A computing device, comprising:
a memory and a processor, wherein the memory and the processor are respectively configured to store and execute instructions, including instructions for causing the computing device to perform operations, the operations including:
providing a standing query;
synchronizing realtime event data regarding a plurality of assets and static event data regarding the plurality of assets, the synchronizing including obtaining the realtime event data for each of the plurality of assets, the realtime event data for each of the plurality of assets representing that asset at a specific point in time, and the specific point in time for each of the plurality of assets being a same point in time;
merging the synchronized realtime event data regarding the plurality of assets and the static event data regarding the plurality of assets, using one or more operators, into an event stream; and
responsive to a changed data source value:
inputting the event stream as a single event type into the standing query; and
outputting multiple assets of the plurality of assets that match the standing query as output of the standing query according to a latency threshold relative to the changed data source value.