Data handling method, system and computer program
The subject application relates to a data handling method for updating lists based on real-time requests and includes: transmitting a first request to a first queue component according to a first request type of the first request; delivering the first request to a first working unit according to a first subscription to the first queue component; and calculating and updating a first list container according to the first request. According to the subject application, it is possible to calculate and update lists based on real-time requests in an efficient and accurate manner.
1. A data handling method for updating lists based on real-time requests, comprising:
transmitting a first request to a first queue component according to a first request type of the first request, wherein the first queue component is a topic of a publish-subscribe service, and the first request is published to the first queue component;
delivering the first request to a first working unit for a first list container that subscribed the first queue component in order to receive the first request; and
calculating and updating the first list container according to the first request, wherein the first working unit includes one or more pod units for handling the first request, and each pod unit is configured to calculate and update one or more list containers.
2. The data handling method according to claim 1 , wherein:
the first request is based on an operation from a user terminal of a user; and
the operation includes an interaction between a streamer and a viewer in a live streaming.
3. The data handling method according to claim 1 , wherein:
the first list container includes a leaderboard showing a ranking in a campaign.
4. The data handling method according to claim 1 , further comprising:
transmitting a second request to a second queue component according to a second request type of the second request; wherein
the first queue component and the second queue component are classified according to the request type of the request.
5. The data handling method according to claim 4 , further comprising:
delivering the second request to a second working unit according to a second subscription to the second queue component; and
calculating and updating a second list container according to the second request; wherein
the first working unit and the second working unit is classified according to the list type of the list.
6. The data handling method according to claim 1 , further comprising:
adjusting a number of pod units in the first working unit dynamically according to a number of requests the first queue component received per second.
7. The data handling method according to claim 6 , further comprising:
increasing the number of pod units in the first working unit in a first time range;
decreasing the number of pod units in the first working unit in a second time range; wherein
the first time range is shorter than the second time range.
8. A data handling system for updating lists based on real-time requests, comprising:
a publisher to a publish-subscribe service configured to transmit a first request to a first queue component according to a first request type of the first request, wherein the first queue component is a topic of the publish-subscribe service, and the first request is published to the first queue component; and
a unit of providing the publish-subscribe service configured to deliver the first request to a subscriber to the publish-subscribe service for a first list container that subscribed the first queue component in order to receive the first request; wherein
the subscriber to the publish-subscribe service is configured to calculate and update the first list container according to the first request, wherein the subscriber to the publish-subscribe service includes one or more pod units for handling the first request, and each pod unit is configured to calculate and update one or more list containers.
9. A computer-readable non-transitory storage device including program instructions, wherein when the program instructions are executed by one or more processors cause the one or more processors to execute:
transmitting a first request to a first queue component according to a first request type of the first request, wherein the first queue component is a topic of a publish-subscribe service and the first request is published to the first queue component;
delivering the first request to a first working unit for a first list container that subscribed the first queue component in order to receive the first request; and
calculating and updating the first list container according to the first request, wherein the first working unit includes one or more pod units for handling the first request, and each pod unit is configured to calculate and update one or more list containers.