Mutations with immediate feedback

Patent metadata

Field	Value
Publication number	US-10891282-B1
Application number	US-201715821698-A
Country	US
Kind code	B1
Filing date	Nov 22, 2017
Priority date	Nov 22, 2017
Publication date	Jan 12, 2021
Grant date	Jan 12, 2021

Abstract

A technology is provided for mutations with immediate feedback. A mutation may be received at a data proxy from an application. The mutation may be sent to a data source via a data access resolver associated with the data proxy. Results of the mutation may be received from the data source. A subscription may be triggered based on receiving the results of the mutation. A message may be sent via a topic provided by the subscription by using a messaging service such that the messaging service publishes the message with the mutation to devices subscribed to the topic.

First claim

What is claimed is:

1. A non-transitory machine readable storage medium having instructions embodied thereon, the instructions when executed cause a processor to perform processing, comprising:
receiving a mutation at a data proxy from an application executing at a client, wherein the data proxy is in a service provider environment;
creating a topic associated with the mutation at the data proxy using a subscription field name and a subscription argument, wherein the data proxy is configured to request that a messaging service setup the topic and to provide the topic to devices;
sending the mutation to a data store via a data access resolver of the data proxy;
receiving results of the mutation from the data store via the data access resolver, wherein the data access resolver determines that the topic is associated with the mutation;
triggering a subscription, associated with the topic, using a field correlating to the results of the mutation; and
sending a message to a topic, linked to the subscription, via the messaging service, wherein the messaging service publishes the message with results of the mutation to the devices subscribed to the topic.

2. The non-transitory machine readable storage medium of claim 1 , wherein the message is sent using at least one of: Message Queue Telemetry Transport (MQTT) protocol, WebSocket protocol, or long polling.

3. The non-transitory machine readable storage medium of claim 1 , wherein the data proxy manages cross account permissions to enable access to data in the data store and manages results returned in response to queries from the client by removing unauthorized fields from the results.

4. The non-transitory machine readable storage medium of claim 1 , further comprising:
receiving a conflict message at the data proxy from the data access resolver for a conflict associated with the mutation at the data store; and
resolving the conflict at the data proxy using a pre-defined function defined in the data proxy.

5. A method, under the control of at least one processor, comprising:
receiving a mutation from an application;
creating a topic associated with the mutation at a data proxy using a subscription field name and a subscription argument, wherein the data proxy is configured to request that a messaging service setup the topic and to provide the topic to devices;
sending the mutation to a data source via a data access resolver;
receiving results of the mutation from the data source, wherein the data access resolver determines that the topic is associated with the mutation;
triggering a subscription, associated with the topic, that correlates to a result of the mutation; and
sending a message to the topic provided by the subscription to the messaging service such that the messaging service publishes the message with the mutation to the devices subscribed to the topic.

6. The method of claim 5 , wherein the data proxy provides connection information to the devices including a topic identifier identifying the topic.

7. The method of claim 5 , wherein the data proxy uses cross account permissions to manage results returned in response to queries from the devices by removing unauthorized fields from the results.

8. The method of claim 5 , wherein the data proxy uses cross account permissions to block the client that is not permitted access.

9. The method of claim 5 , wherein the message is sent using at least one of: Message Queue Telemetry Transport (MQTT) protocol, WebSocket protocol, or long polling.

10. The method of claim 5 , wherein the mutation is one of a plurality of mutations stored at a cache at a client associated with the application while the client was offline and was sent to the data proxy after the client connected to the data proxy.

11. The method of claim 5 , wherein the data source is a data store selected from a group of data stores consisting of: an object data store, a key-value data store, a relational database, and a search service.

12. The method of claim 5 , wherein the data source is a code function that is a segment of program code executing on a code function service.

13. The method of claim 5 , wherein the data proxy includes more than one version of a data schema and the mutation is handled by the data proxy using a version of the data schema employed by a client associated with the application.

14. The method of claim 5 , further comprising:
receiving a plurality of mutations at the data proxy from a plurality of clients; and
triggering subscriptions for each of the mutations.

15. The method of claim 5 , further comprising:
receiving a conflict message at the data proxy via the data access resolver for a conflict associated with the mutation at the data source; and
resolving the conflict at the data proxy using a pre-defined function defined in the data proxy.

16. The method of claim 15 , wherein a code function executing on a program code service sends values associated with the conflict message to the application and receives a selection of a value to write to the data source.

17. The method of claim 5 , wherein the messaging service is based on a publish-subscribe model wherein messages are sent via topics devices that are subscribed to the topics.

18. A system, comprising:
a data proxy:
at least one processor; and
a memory device including instructions to be executed by the at least one processor in order to:
identify a topic at the data proxy for a subscription using at least one subscription field name and a subscription argument, wherein the data proxy is configured to request that a messaging service setup the topic and to provide the topic to devices;
receive a mutation at the data proxy from an application executing at a first client, wherein the data proxy is in a service provider environment;
send the mutation to a data store via a data access resolver;
receive results of the mutation from the data store, wherein the data access resolver determines that the topic is associated with the mutation;
trigger a subscription, associated with the topic, associated with the results of the mutation; and
send a message for the topic associated with the subscription to the messaging service which publishes the message with the mutation to the devices subscribed to the topic.

19. The system of claim 18 , the instructions further comprising:
receive plurality of mutations at the data proxy from a plurality of clients; and
trigger subscriptions for each of the mutations.

20. The system of claim 18 , the instructions further comprising:
store the subscription as metadata.

Assignees

• Amazon Tech Inc

Inventors

• Willingham Michael B
• Deshpande Rohan
• Shon Lisa Meenhee
• Saligrama Shreeram Karthik
• Dowling Christopher Nathan
• Patel Amit
• Bailey Jeffrey H
• Boyer Antoine Francois Charles
• Threlkeld Richard
• Paris Michael
• Srivastava Mohit

Classifications

• H04L67/56

  Provisioning of proxy services (store-and-forward switching systems in data switching networks H04L12/54) · CPC title

• G06F21/64

  Protecting data integrity, e.g. using checksums, certificates or signatures · CPC title

• H04L63/1458

  Denial of Service · CPC title

• H04L63/101

  Access control lists [ACL] · CPC title

• G06F21/554

  involving event detection and direct action · CPC title