Data notification system for health data

Abstract

Systems, methods, and computer program products to perform an operation comprising receiving a request specifying to receive notifications for updates to data in a multi-tenant data store for a first group comprising a plurality of people, translating the request based on a set of mappings to reflect a physical representation of the data in the data store, generating a notification reflecting an update to data in the data store for a first person of the plurality of people, and storing the notification on a streaming platform for access by a first client application, wherein the notification comprises data describing a location of the updated data in the multi-tenant data store.

1 . A method, comprising:
 receiving a request specifying to receive notifications for updates to data in a multi-tenant data store for a first group comprising a plurality of people;   translating the request based on a set of mappings to reflect a physical representation of the data in the data store;   generating a notification reflecting an update to data in the data store for a first person of the plurality of people; and   storing the notification on a streaming platform for access by a first client application, wherein the notification comprises data describing a location of the updated data in the multi-tenant data store.   
     
     
         2 . The method of  claim 1 , wherein the request is received from a client application, wherein the data describing the location of the updated data comprises: (i) a tenant identifier associated with the client application in the multi-tenant data store, (ii) a database table storing the updated data in the multi-tenant data store, and (iii) a key value associated with the first person in the database table. 
     
     
         3 . The method of  claim 2 , further comprising:
 receiving, by a query server from the client application, a query targeting the data store based on the data describing the location of the updated data;   processing the received query against the data store; and   returning a result set to the client application as responsive to the query.   
     
     
         4 . The method of  claim 3 , wherein the notification is associated with a first topic, of the plurality of topics managed by the streaming platform, wherein the streaming platform stores the notifications for consumption by the client application, wherein the notification and the updated data are secured based on a security key provided in the request. 
     
     
         5 . The method of  claim 4 , further comprising:
 determining that the update to the data has been generated in a processing pipeline; and   determining that the first topic is associated with updates to the updated data.   
     
     
         6 . The method of  claim 5 , further comprising:
 receiving, by the streaming platform, an indication from the client application to access the notification;   authenticating the client application based on the security key; and   transmitting, by a websocket server, the notification to the client application.   
     
     
         7 . The method of  claim 4 , further comprising:
 determining that a second topic is associated with updates to the updated data;   generating a second notification reflecting the update to the updated data for the second topic; and   storing, by the streaming platform, the second notification in the second topic.   
     
     
         8 . A computer program product, comprising:
 a non-transitory computer-readable storage medium having computer readable program code embodied therewith, the computer readable program code executable by a processor to perform an operation comprising:
 receiving a request specifying to receive notifications for updates to data in a multi-tenant data store for a first group comprising a plurality of people; 
 translating the request based on a set of mappings to reflect a physical representation of the data in the data store; 
 generating a notification reflecting an update to data in the data store for a first person of the plurality of people; and 
 storing the notification on a streaming platform for access by a first client application, wherein the notification comprises data describing a location of the updated data in the multi-tenant data store. 
   
     
     
         9 . The computer program product of  claim 8 , wherein the request is received from a client application, wherein the data describing the location of the updated data comprises: (i) a tenant identifier associated with the client application in the multi-tenant data store, (ii) a database table storing the updated data in the multi-tenant data store, and (iii) a key value associated with the first person in the database table. 
     
     
         10 . The computer program product of  claim 9 , the operation further comprising:
 receiving, by a query server from the client application, a query targeting the data store based on the data describing the location of the updated data;   processing the received query against the data store; and   returning a result set to the client application as responsive to the query.   
     
     
         11 . The computer program product of  claim 10 , wherein the notification is associated with a first topic, of the plurality of topics managed by the streaming platform, wherein the streaming platform stores the notifications for consumption by the client application, wherein the notification and the updated data are secured based on a security key provided in the request. 
     
     
         12 . The computer program product of  claim 11 , the operation further comprising:
 determining that the update to the data has been generated in a processing pipeline; and   determining that the first topic is associated with updates to the updated data.   
     
     
         13 . The computer program product of  claim 13 , the operation further comprising:
 receiving, by the streaming platform, an indication from the client application to access the notification;   authenticating the client application based on the security key; and   transmitting, by a websocket server, the notification to the client application.   
     
     
         14 . The computer program product of  claim 11 , further comprising:
 determining that a second topic is associated with updates to the updated data;   generating a second notification reflecting the update to the updated data for the second topic; and   storing, by the streaming platform, the second notification in the second topic.   
     
     
         15 . A system, comprising:
 a processor; and   a memory storing one or more instructions which, when executed by the processor, performs an operation comprising:
 receiving a request specifying to receive notifications for updates to data in a multi-tenant data store for a first group comprising a plurality of people; 
 translating the request based on a set of mappings to reflect a physical representation of the data in the data store; 
 generating a notification reflecting an update to data in the data store for a first person of the plurality of people; and 
 storing the notification on a streaming platform for access by a first client application, wherein the notification comprises data describing a location of the updated data in the multi-tenant data store. 
   
     
     
         16 . The system of  claim 15 , wherein the request is received from a client application, wherein the data describing the location of the updated data comprises: (i) a tenant identifier associated with the client application in the multi-tenant data store, (ii) a database table storing the updated data in the multi-tenant data store, and (iii) a key value associated with the first person in the database table. 
     
     
         17 . The system of  claim 16 , the operation further comprising:
 receiving, by a query server from the client application, a query targeting the data store based on the data describing the location of the updated data;   processing the received query against the data store; and   returning a result set to the client application as responsive to the query.   
     
     
         18 . The system of  claim 17 , wherein the notification is associated with a first topic, of the plurality of topics managed by the streaming platform, wherein the streaming platform stores the notifications for consumption by the client application, wherein the notification and the updated data are secured based on a security key provided in the request. 
     
     
         19 . The system of  claim 18 , the operation further comprising:
 determining that the update to the data has been generated in a processing pipeline; and   determining that the first topic is associated with updates to the updated data.   
     
     
         20 . The system of  claim 15 , the operation further comprising:
 receiving, by the streaming platform, an indication from the client application to access the notification;   authenticating the client application based on the security key; and   transmitting, by a websocket server, the notification to the client application.