Method, apparatus, device and medium for managing data processing system

An electronic device, comprising:

• at least one processor;
• and
• at least one memory coupled to the at least one processor and storing instructions for execution by the at least one processor, the instructions, when executed by the at least one processor, causing the electronic device to perform acts comprising:
• obtaining a set of messages from a message queue of the data processing system, the set of messages respectively corresponding to a set of data items in the data processing system;
• determining a delay time corresponding to the set of messages, the delay time indicating a query time for querying a processing state of the set of data items in at least one processing node in the data processing system;
• starting at least one querier in the data processing system based on the delay time, the set of data items being processed by the at least one processing node, and the at least one querier being configured to query the processing state of the set of data items in the at least one processing node;
• and
• managing the data processing system based on the processing state.

A non-transitory computer-readable storage medium having stored thereon computer instructions that, when executed by a processor, cause the processor to perform acts comprising:

• obtaining a set of messages from a message queue of the data processing system, the set of messages respectively corresponding to a set of data items in the data processing system;
• determining a delay time corresponding to the set of messages, the delay time indicating a query time for querying a processing state of the set of data items in at least one processing node in the data processing system;
• starting at least one querier in the data processing system based on the delay time, the set of data items being processed by the at least one processing node, and the at least one querier being configured to query the processing state of the set of data items in the at least one processing node;
• and
• managing the data processing system based on the processing state.