Asynchronous distributed data cleansing
US-2019129981-A1 · May 2, 2019 · US
US11366805B2 · US · B2
| Field | Value |
|---|---|
| Publication number | US-11366805-B2 |
| Application number | US-201916264470-A |
| Country | US |
| Kind code | B2 |
| Filing date | Jan 31, 2019 |
| Priority date | Sep 24, 2018 |
| Publication date | Jun 21, 2022 |
| Grant date | Jun 21, 2022 |
A practical reading order for non-experts. Skip the full description unless you need deep technical detail.
What the patent document calls the invention.
A short plain-language summary of the technical disclosure.
Who owns or filed the patent and who is credited as inventor.
Filing, priority, publication, and grant dates set the timeline.
The legal scope of protection — read this for what is actually claimed.
Technology tags used to group this patent with similar filings.
Prior art links and similar publications in this corpus.
Official abstract text for this publication.
Methods, systems, and computer program products for a customer relationship management (CRM) system are provided herein. Embodiments presented herein provide for exchange of data between disparate, distributed systems; subscribe to and/or publish customer data change event; creation of master records for consumers using static and streaming sources; providing data provenance, auditing capabilities, and queries across multiple tenants and third party systems. Embodiments provide a single view of a customer in a distributed system environment.
Opening claim text (preview).
What is claimed is: 1. A system, comprising: a memory; a processor coupled to the memory and configured to, based on instructions stored in the memory, perform operations comprising: retrieving first patron data related to a patron off a platform bus based on a first subscription rule, wherein the first subscription rule is triggered in response to publishing of the first patron data related to the patron from a first data source to the platform bus; retrieving second patron data related to the patron off the platform bus based on a second subscription rule, wherein the second subscription rule is triggered in response to publishing of the second patron data related to the patron from a second data source different from the first data source to the platform bus and wherein the first and second subscription rules are defined by an individual client that manages the first and second data sources; formatting the first patron data and the second patron data into a standard format based on context information of the first patron data and the second patron data; matching the first and second patron data with existing records related to the patron; creating a master record for the patron using the formatted first patron data, the formatted second patron data, and the existing records, wherein the master record comprises a record of the first and second data sources for the formatted first and second patron data; receiving, via an event bus, raw events related to the patron from a third data source, wherein the raw events are generated based on an activity of the patron on the third data source; converting the raw events into a customer trigger event for the patron based on a predetermined rule; generating, in response to the customer trigger event, a notification for the patron, wherein the notification is enriched with information of the patron in the master record; and sending the notification to the patron based on contact information of the patron in the master record. 2. The system according to claim 1 , the operations further comprising: transmitting a master record event in response to a change event of the master record onto the platform bus for data sources subscribed to the master record. 3. The system according to claim 1 , the operations further comprising: updating the master record for the patron using the formatted first patron data, the formatted second patron data, and the existing records. 4. The system according to claim 1 , the operations further comprising: performing a query of information associated with the patron in the master record from the first data source and the second data source through a global directory of tenants. 5. The system according to claim 1 , the operations further comprising performing a commerce journey event in response to the first patron data, wherein the commerce journey event generates a notification comprising information in the master record for the patron to respond to the first patron data and sends the notification to the patron. 6. The system according to claim 1 , the operations further comprising reconciling data obtained from the formatted first patron data, the formatted second patron data, and the existing records in a single view of the patron. 7. A method, comprising: retrieving, by a computing device, first patron data related to a patron off a platform bus based on a first subscription rule, wherein the first subscription rule is triggered in response to publishing of the first patron data related to the patron from a first data source to the platform bus; retrieving, by the computing device, second patron data related to the patron off the platform bus based on a second subscription rule, wherein the second subscription rule is triggered in response to publishing of the second patron data related to the patron from a second data source different from the first data source to the platform bus and wherein the first and second subscription rules are defined by an individual client that manages the first and second data sources; formatting, by the computing device, the first patron data and the second patron data into a standard format based on context information of the first patron data and the second patron data; matching, by the computing device, the first and second patron data with existing records; creating, by the computing device, a master record for the patron using the formatted first patron data, the formatted second patron data, and the existing records, wherein the master record comprises a record of the first and second data sources for the formatted first and second patron data; receiving, via an event bus, raw events related to the patron from a third data source, wherein the raw events are generated based on an activity of the patron on the third data source; converting the raw events into a customer trigger event for the patron based on a predetermined rule; generating, in response to the customer trigger event, a notification for the patron, wherein the notification is enriched with information of the patron in the master record; and sending the notification to the patron based on contact information of the patron in the master record. 8. The method according to claim 7 , further comprising: transmitting, by the computing device, a master record event in response to a change event of the master record onto the platform bus for data sources subscribed to the master record. 9. The method according to claim 7 , further comprising: updating, by the computing device, the master record for the patron using the formatted first patron data, the formatted second patron data, and the existing records. 10. The method according to claim 7 , further comprising: performing, by the computing device, a query of information associated with the patron in the master record from the first data source and the second data source accessible through a global directory of tenants. 11. The method according to claim 7 , further comprising performing a commerce journey event in response to the first patron data, wherein the commerce journey event generates a notification comprising information in the master record for the patron to respond to the first patron data and sends the notification to the patron. 12. The method according to claim 7 , further comprising: reconciling, by the computing device, data obtained from the formatted first patron data, the formatted second patron data, and the existing records; and providing, by the computing device, a single view of the patron based on the reconciled data. 13. A non-transitory computer-readable apparatus having instructions stored thereon that, when executed by a computing device, cause the computing device to perform operations comprising: retrieving, by a computing device, first patron data related to a patron off a platform bus based on a first subscription rule, wherein the first subscription rule is triggered in response to publishing of the first patron data related to the patron from a first data source to the platform bus; retrieving, by the computing device, second patron data related to the patron off the platform bus based on a second subscription rule, wherein the second subscription rule is triggered in response to publishing of the second patron data related to the patron from a second data source different from the first data source to the platform bus and wherein the first and second subscription rules are defined by an individual client that manages the first and second data sources; formatting, by the computing device, the first patron data and the second patron data into a standard format based on context
Improving data quality; Data cleansing, e.g. de-duplication, removing invalid entries or correcting typographical errors · CPC title
with details for data modelling support · CPC title
Event management; Broadcasting; Multicasting; Notifications · CPC title
Distributed queries · CPC title
Data format conversion from or to a database · CPC title
Related publications grouped by family.
Answers are generated from the same data shown on this page.