[go: up one dir, main page]

WO2024183529A1 - Data processing method and apparatus for medical device, electronic device, and medium - Google Patents

Data processing method and apparatus for medical device, electronic device, and medium Download PDF

Info

Publication number
WO2024183529A1
WO2024183529A1 PCT/CN2024/076645 CN2024076645W WO2024183529A1 WO 2024183529 A1 WO2024183529 A1 WO 2024183529A1 CN 2024076645 W CN2024076645 W CN 2024076645W WO 2024183529 A1 WO2024183529 A1 WO 2024183529A1
Authority
WO
WIPO (PCT)
Prior art keywords
data processing
data
processed
processing engine
script
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
PCT/CN2024/076645
Other languages
French (fr)
Chinese (zh)
Inventor
于震江
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Beijing Jingdong Tuoxian Technology Co Ltd
Original Assignee
Beijing Jingdong Tuoxian Technology Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Beijing Jingdong Tuoxian Technology Co Ltd filed Critical Beijing Jingdong Tuoxian Technology Co Ltd
Publication of WO2024183529A1 publication Critical patent/WO2024183529A1/en
Anticipated expiration legal-status Critical
Pending legal-status Critical Current

Links

Classifications

    • GPHYSICS
    • G16INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR SPECIFIC APPLICATION FIELDS
    • G16HHEALTHCARE INFORMATICS, i.e. INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR THE HANDLING OR PROCESSING OF MEDICAL OR HEALTHCARE DATA
    • G16H40/00ICT specially adapted for the management or administration of healthcare resources or facilities; ICT specially adapted for the management or operation of medical equipment or devices
    • G16H40/60ICT specially adapted for the management or administration of healthcare resources or facilities; ICT specially adapted for the management or operation of medical equipment or devices for the operation of medical equipment or devices
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/22Indexing; Data structures therefor; Storage structures
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/22Indexing; Data structures therefor; Storage structures
    • G06F16/2228Indexing structures
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/24Querying
    • G06F16/245Query processing
    • G06F16/2458Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
    • GPHYSICS
    • G06COMPUTING OR CALCULATING; COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F16/00Information retrieval; Database structures therefor; File system structures therefor
    • G06F16/20Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
    • G06F16/24Querying
    • G06F16/245Query processing
    • G06F16/2458Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
    • G06F16/2471Distributed queries

Definitions

  • the present disclosure relates to the field of medical health technology, and in particular to a data processing method, device, electronic device and storage medium for medical equipment.
  • Medical devices for example, wearable medical devices as one of the main data interfaces are receiving more and more attention.
  • Medical devices can collect various physiological index data of the human body, process the physiological index data collected by the medical devices, obtain data processing results, and then analyze the data processing results to obtain information with relevant medical significance.
  • a data processing script corresponding to the data to be processed is compiled, and then the data to be processed can be processed based on the data processing script.
  • the present disclosure aims to solve one of the technical problems in the related art at least to some extent.
  • the purpose of the present disclosure is to provide a data processing method, device, electronic device and storage medium for medical equipment.
  • An embodiment of one aspect of the present disclosure proposes a data processing method for medical devices, which is executed by a distributed processing engine, and includes: obtaining data to be processed and a device identifier, wherein the device identifier is used to identify the medical device to which the data to be processed belongs; if a target data processing engine matching the device identifier is found from multiple initial data processing engines pre-stored in a local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine includes at least: a debugged data processing script corresponding to the device identifier, and the data processing script is used to process the data to be processed.
  • An embodiment of another aspect of the present disclosure proposes a data processing method for medical devices, which is executed by a target data processing engine, and the target data processing engine at least includes: a data processing script, and the method includes: receiving data to be processed from a medical device sent by a distributed processing engine, wherein the medical device to which the data to be processed belongs has a device identification; processing the data to be processed according to the data processing script, wherein the data processing script corresponds to the device identification.
  • An embodiment of another aspect of the present disclosure proposes a data processing device for medical equipment, which is executed by a distributed processing engine, and the device includes: an acquisition module, used to acquire data to be processed and a device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs; a sending module, used to send the data to be processed to the target data processing engine when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in a local database, wherein the target data processing engine includes at least: a debugged data processing script corresponding to the device identification, and the data processing script is used to process the data to be processed.
  • An embodiment of another aspect of the present disclosure proposes a data processing device for medical equipment, wherein the target data processing engine at least includes: a data processing script, and the device includes: a receiving module for receiving the data to be processed of the medical equipment sent by the distributed processing engine, wherein the medical equipment to which the data to be processed belongs has a device identification; and a processing module for processing the data to be processed according to the data processing script, wherein the data processing script corresponds to the device identification.
  • An embodiment of another aspect of the present disclosure provides an electronic device, comprising a memory, a processor, and a computer program stored in the memory and executable on the processor.
  • the processor executes the program, it implements the data processing method for a medical device as proposed in the embodiment of the first aspect of the present disclosure, or implements the data processing method for a medical device as proposed in the embodiment of the second aspect of the present disclosure.
  • An embodiment of another aspect of the present disclosure proposes a non-temporary computer-readable storage medium having a computer program stored thereon, which, when executed by a processor, implements the data processing method for a medical device as proposed in the embodiment of the first aspect of the present disclosure, or implements the data processing method for a medical device as proposed in the embodiment of the second aspect of the present disclosure.
  • An embodiment of another aspect of the present disclosure proposes a computer program product.
  • an instruction processor in the computer program product executes, it executes the data processing method for a medical device as proposed in the embodiment of the first aspect of the present disclosure, or implements the data processing method for a medical device as proposed in the embodiment of the second aspect of the present disclosure.
  • FIG1 is a flow chart of a data processing method for medical equipment according to an embodiment of the present disclosure
  • FIG3 is a flow chart of a data processing method for medical equipment according to another embodiment of the present disclosure.
  • FIG4 is a flow chart of a data processing method for medical equipment according to another embodiment of the present disclosure.
  • FIG. 5 is a flowchart of a data processing method for medical equipment according to an embodiment of the present disclosure. Process diagram
  • FIG6 is a schematic diagram of the structure of a data processing device for medical equipment according to an embodiment of the present disclosure.
  • FIG7 is a schematic diagram of the structure of a data processing device for medical equipment proposed in an embodiment of the present disclosure.
  • FIG8 shows a block diagram of an exemplary electronic device suitable for implementing embodiments of the present disclosure.
  • FIG1 is a flow chart of a data processing method for medical equipment proposed in an embodiment of the present disclosure.
  • the executor of the data processing method for medical equipment in this embodiment is a data processing device for medical equipment, which can be implemented by software and/or hardware.
  • the device can be configured in an electronic device, and the electronic device may include but is not limited to a terminal, a server, etc.
  • the data processing method for medical equipment is executed by a distributed processing engine
  • the distributed processing engine may be, for example, Flink, without limitation.
  • S101 Acquire data to be processed and a device identifier, where the device identifier is used to identify the medical device to which the data to be processed belongs.
  • the medical device may specifically be a wearable medical device, and the medical device may specifically be a smart blood pressure meter, a smart blood glucose meter, etc., without limitation.
  • the data processing method for medical equipment described in the embodiments of the present disclosure can be used to process relevant data of the medical equipment, and the relevant data can specifically be, for example, human body indicator data monitored by the medical equipment for the user (for example, blood pressure data, blood sugar data, without limitation).
  • relevant data can specifically be, for example, human body indicator data monitored by the medical equipment for the user (for example, blood pressure data, blood sugar data, without limitation).
  • the device identifier may be used to identify a unique medical device, and the device identifier may be, for example, the name of the medical device, the serial number of the medical device, etc., without limitation.
  • obtaining the data to be processed and the device identification can be to pre-build a data transmission link between the medical device and Flink, and then Flink can obtain the relevant indicator data of the medical device as the data to be processed based on the data transmission link between the medical device and Flink, and obtain the device number of the medical device as the device identification, without limitation.
  • Figure 2 is a flow chart of the transmission of pending data proposed in an embodiment of the present disclosure.
  • the data to be processed and the device identification can be obtained by the MQTT Cluster monitoring the medical device, and when the medical device generates the data to be processed, the data to be processed and the device identification are reported to the MQTT Broker in the MQTT Cluster.
  • the MQTT Broker plug-in can be pre-integrated with the Kafka Topic mapping rules in the Kafka Client, so that after obtaining the data to be processed and the device identification reported by the medical device, the data to be processed and the device identification can be mapped to the Kafka Topic in the Kafka Client, and then Flink can obtain the corresponding data to be processed and the device identification from the Kafka Topic.
  • the target data processing engine at least includes: a debugged data processing script corresponding to the device identifier (the data processing script can be specifically, for example, a (Java Script, JS) script.
  • the data processing script can be specifically, for example, a (Java Script, JS) script.
  • the initial data processing engine is a script engine pre-stored in the local database of the platform to which the distributed processing engine belongs, and is used to process the data to be processed based on the data processing script.
  • the initial data processing engine can be specifically, for example, a JS engine (the main function of the JS engine is to compile and execute scripts in combination with the characteristics of the JS script), and the target data processing engine is the initial data processing engine in the initial data processing engine that is adapted to the data to be processed.
  • the target data processing engine can process the data to be processed based on the data processing script.
  • the debugged data processing script can be directly used to process the data to be processed, thereby effectively simplifying the data processing operation process.
  • the target data processing engine after obtaining the data to be processed and the device identification, it is possible to search whether there is a target data processing engine corresponding to the device identification in the local database of the platform to which the distributed processing engine belongs, and when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in the local database, the data to be processed is sent to the target data processing engine, and then, the target data processing engine can process the data to be processed based on compiling and executing the data processing script.
  • the data to be processed can be sent to the target data processing engine, and then the target data processing engine can process the data to be processed based on the data processing script to implement the present disclosure.
  • the data processing method for medical equipment described in the embodiment can be specifically referred to in the subsequent embodiments, which will not be described in detail here.
  • the device identification is used to identify the medical device to which the data to be processed belongs, and when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in a local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identification, and the data processing script is used to process the data to be processed.
  • the target data processing engine used to process the data to be processed based on the device identification, and because the data processing engine contains a pre-debugged data processing script corresponding to the device identification, there is no need to repeatedly introduce a series of debugging processes such as development, joint debugging, testing, and online release of the data processing script, and then when the data to be processed is sent to the target data processing engine, the target data processing engine can directly complete the processing of the data to be processed based on the compiled data processing script, thereby effectively simplifying the data processing operation process.
  • FIG3 is a flow chart of a data processing method for medical equipment proposed in another embodiment of the present disclosure.
  • the data processing method for medical equipment includes:
  • the medical device when a certain medical device is introduced, the medical device may be registered on the platform to which the distributed processing engine belongs to obtain a candidate device identification of each medical device.
  • the candidate processing script can be used to process the medical device identified by the corresponding candidate identifier. data to be processed.
  • the embodiment of the present disclosure can compile a corresponding candidate processing script for each candidate device identification, and then trigger the execution of subsequent data processing methods for the medical device based on the candidate processing script, without limitation.
  • the embodiment of the present disclosure can store the candidate processing script in a cloud database, and then, in the subsequent execution of the data processing method for the medical device, support the rapid call of the pre-stored candidate processing script from the cloud database.
  • S304 Determine the storage address of each candidate processing script in the cloud database.
  • the storage address of the candidate processing script in the cloud database may be, for example, a resource locator of the candidate processing script in the cloud database, and there is no limitation on this.
  • the embodiment of the present disclosure may determine the resource locator of each candidate processing script in the cloud database as the storage address.
  • S305 Store the storage address in the local database of the platform to which the distributed processing engine belongs.
  • the embodiment of the present disclosure may store the storage address in the local database of the platform to which the distributed processing engine belongs.
  • the index item can be used to obtain the corresponding storage address from the local database.
  • the storage address of each candidate processing script in the cloud database by determining the storage address of each candidate processing script in the cloud database, and storing the storage address in the local database of the platform to which the distributed processing engine belongs, and then assigning an index item to the storage address stored in the local database, since the storage address of the candidate processing script in the cloud database is stored in the local database, the storage resources of the local database can be effectively saved, and by assigning an index item to the storage address stored in the local database, the storage address can be conveniently obtained from the local database.
  • assigning an index item to a storage address stored in a local database may be performed by using the last character of the storage address as the index item of the storage address stored in the local database, and there is no limitation to this.
  • an index item is assigned to the storage address stored in the local database.
  • the last character “1” can be used as the index item of the storage address "asdgjfkl111" in the local database. There is no limitation on this.
  • assigning an index item to a storage address stored in a local database may be accomplished by configuring a candidate device identifier as an index item of a storage address stored in the local database, and then, during the execution of a data processing method for a medical device, the storage address of a candidate processing script corresponding to the device identifier may be accurately called according to the device identifier.
  • S307 Acquire the data to be processed and the device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs.
  • the candidate device identification of each medical device when the medical device is registered on the platform to which the distributed processing engine belongs, and obtaining the candidate processing script corresponding to each candidate device identification, and then storing the candidate processing script in the cloud database, it is possible to support the rapid call of pre-stored candidate processing scripts from the cloud database in the subsequent execution process of the data processing method for the medical device, determine the storage address of each candidate processing script in the cloud database, store the storage address in the local database of the platform to which the distributed processing engine belongs, and then assign index items to the storage addresses stored in the local database. Since the storage addresses of the candidate processing scripts in the cloud database are stored in the local database, the storage resources of the local database can be effectively saved.
  • the storage address is obtained from the database, and then the data to be processed and the device identification are obtained, the device identification is used to identify the medical device to which the data to be processed belongs, and when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in the local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identification, the data processing script is used to process the data to be processed, and since the data processing engine contains a pre-debugged data processing script corresponding to the device identification, there is no need to repeatedly introduce a series of debugging processes such as development, joint debugging, testing, and online launch of the data processing script, and then when the data to be processed is sent to the target data processing engine, the target data processing engine can directly complete the processing of the data to be processed based on the compiled data
  • FIG. 4 is a flow chart of a data processing method for medical equipment proposed in another embodiment of the present disclosure.
  • the data processing method for medical equipment includes:
  • S401 Obtain the data to be processed and the device identification, wherein the device identification is used to identify the data to be processed.
  • the medical device that processes the data is a device that processes the data.
  • the target data processing engine after obtaining the data to be processed and the device identification, it is possible to search whether there is a target data processing engine corresponding to the device identification in the local database of the platform to which the distributed processing engine belongs, and when the target data processing engine that matches the device identification is not found from the multiple initial data processing engines pre-stored in the local database, the target data processing engine is constructed based on the data processing script, and then, the target data processing engine can process the data to be processed based on compiling and executing the data processing script.
  • a target index item corresponding to the device identifier can also be determined from multiple index items in the local database, wherein each index item is used to index a storage address, and based on the storage address indexed from the local database by the target index item, the data processing script is determined from multiple candidate processing scripts stored in the cloud database based on the storage address obtained by the index.
  • the index item corresponding to the device identifier determined from among the multiple index items in the local database may be referred to as the target index item.
  • the target index item corresponding to the device identifier can be determined from the local database, and then the storage address obtained by indexing from the local database based on the target index item can be used to determine the data processing script from multiple candidate processing scripts stored in the cloud database according to the storage address obtained by indexing.
  • the acquired data processing script can match the device identifier, so that in the subsequent execution process of the processing method for the medical device, it can be ensured that the constructed data processing engine can Supports processing of data identified by corresponding devices.
  • a target index item corresponding to a device identifier is determined from multiple index items in a local database. This may be by determining multiple candidate device identifiers from the local database, and determining a candidate device identifier that is identical to the device identifier among the multiple candidate device identifiers, and then using the identical candidate device identifier as the target index item.
  • a candidate device identifier that is identical to the device identifier can be determined from multiple candidate device identifiers stored in the local database, and the candidate device identifier that is identical to the device identifier can be used as the target index item. Then, based on the target index item, a storage address can be indexed from the local database, and then, according to the storage address obtained by indexing, a data processing script can be determined from multiple candidate processing scripts stored in the cloud database.
  • the device identification is used to identify the medical device to which the data to be processed belongs, and determining the search result obtained by searching the data processing engine in the local database, and then determining the target determination method of the data processing engine based on the search result, and determining the data processing engine corresponding to the device identification based on the target determination method, thereby, the data processing engine corresponding to the device identification can be accurately determined based on the target determination method, and then the data to be processed is sent to the data processing engine, thereby, a suitable data processing engine can be provided for the data to be processed, thereby effectively simplifying the data processing operation process and effectively improving the data processing effect.
  • FIG. 5 is a flowchart of a data processing method for medical equipment according to an embodiment of the present disclosure. Process diagram.
  • the executor of the data processing method for medical equipment in this embodiment is a data processing device for medical equipment, which can be implemented by software and/or hardware.
  • the device can be configured in an electronic device, and the electronic device may include but is not limited to a terminal, a server, etc.
  • the data processing method for medical equipment is executed by a target data processing engine, which at least includes: a data processing script.
  • the target data processing engine can be specifically, for example, a JS engine.
  • the data processing script can be specifically, for example, a JS script, without limitation.
  • S501 Receive data to be processed of a medical device sent by a distributed processing engine, wherein the medical device to which the data to be processed belongs has a device identifier.
  • the data to be processed of the medical device sent by the distributed processing engine can be received via a data transmission link between the distributed processing engine and the target data processing engine. Then, the data to be processed can be processed by the target data processing engine.
  • the data to be processed can be processed by the target data processing engine.
  • S502 Process the data to be processed according to a data processing script, wherein the data processing script corresponds to the device identifier.
  • the target data processing engine after receiving the data to be processed of the medical device sent by the distributed processing engine, can process the data to be processed according to the data processing script.
  • the data to be processed of the medical device sent by the distributed processing engine is received, wherein the medical device to which the data to be processed belongs has a device identification, and the data to be processed is processed according to the data processing script, wherein the data processing script corresponds to the device identification.
  • the data processing script can be independently compiled in the target data processing engine, and can support independent operation between multiple engines, effectively avoiding mutual influence between the simultaneous processing of multiple device data, and effectively ensuring the data processing effect.
  • FIG6 is a schematic diagram of the structure of a data processing device for medical equipment proposed in an embodiment of the present disclosure.
  • the data processing device 60 for medical equipment includes:
  • An acquisition module 601 is used to acquire the data to be processed and the device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs;
  • the sending module 602 is used to send the data to be processed to the target data processing engine when a target data processing engine matching the device identifier is found from multiple initial data processing engines pre-stored in the local database, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identifier, and the data processing script is used to process the data to be processed.
  • the data processing device 60 for medical equipment is further used to:
  • the candidate processing scripts are stored in a cloud database.
  • the data processing device 60 for medical equipment is further used to:
  • the data processing device 60 for medical equipment is further used to:
  • the candidate device identification is configured as an index item of the storage address stored in the local database.
  • the data processing device 60 for medical equipment is further used to:
  • a data processing script is determined from a plurality of candidate processing scripts stored in the cloud database.
  • the data processing device 60 for medical equipment is further used to:
  • the same candidate device identifier is used as the target index item.
  • the data processing device 60 for medical equipment is further used to:
  • the target data processing engine is constructed based on the data processing script.
  • the present disclosure further provides a data processing device for medical equipment. Since the data processing device for medical equipment provided in the embodiments of the present disclosure is consistent with the data processing method for medical equipment provided in the embodiments of FIGS. 1 to 5 above, The provided data processing method for medical equipment corresponds to the data processing method for medical equipment, so the implementation of the data processing method for medical equipment is also applicable to the data processing device for medical equipment provided in the embodiment of the present disclosure, and will not be described in detail in the embodiment of the present disclosure.
  • the device identification is used to identify the medical device to which the data to be processed belongs, and when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in a local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identification, and the data processing script is used to process the data to be processed.
  • the target data processing engine used to process the data to be processed based on the device identification, and because the data processing engine contains a pre-debugged data processing script corresponding to the device identification, there is no need to repeatedly introduce a series of debugging processes such as development, joint debugging, testing, and online launch of the data processing script, and then when the data to be processed is sent to the target data processing engine, the target data processing engine can directly complete the processing of the data to be processed based on the compiled data processing script, thereby effectively simplifying the data processing operation process.
  • FIG. 7 is a schematic diagram of the structure of a data processing device for medical equipment proposed in an embodiment of the present disclosure.
  • the data processing device 70 for medical equipment includes:
  • the receiving module 701 is used to receive the to-be-processed data of the medical device sent by the distributed processing engine, wherein the medical device to which the to-be-processed data belongs has a device identification;
  • the processing module 702 is used to process the data to be processed according to the data processing script, wherein the data processing script corresponds to the device identifier.
  • the present disclosure further provides a data processing device for medical equipment. Since the data processing device for medical equipment provided in the embodiments of the present disclosure corresponds to the data processing method for medical equipment provided in the embodiments of FIGS. 1 to 5 above, The implementation of the data processing method is also applicable to the data processing device for medical equipment provided in the embodiment of the present disclosure, and will not be described in detail in the embodiment of the present disclosure.
  • the data to be processed of the medical device sent by the distributed processing engine is received, wherein the medical device to which the data to be processed belongs has a device identification, and the data to be processed is processed according to a data processing script, wherein the data processing script corresponds to the device identification.
  • the data processing script can be independently compiled in the target data processing engine, and can support independent operation between multiple engines, effectively avoiding mutual influence between the simultaneous processing of data from multiple devices, and effectively ensuring the data processing effect.
  • the present disclosure also proposes an electronic device, including: a memory, a processor, and a computer program stored in the memory and executable on the processor.
  • the processor executes the program, it implements the data processing method for medical equipment proposed in the above embodiments of the present disclosure.
  • the present disclosure also proposes a non-temporary computer-readable storage medium on which a computer program is stored.
  • the program When the program is executed by a processor, it implements the data processing method for medical equipment proposed in the above embodiments of the present disclosure.
  • the present disclosure further proposes a computer program product.
  • an instruction processor in the computer program product executes, the data processing method for a medical device proposed in the above embodiments of the present disclosure is executed.
  • Fig. 8 shows a block diagram of an exemplary electronic device suitable for implementing the embodiments of the present disclosure.
  • the electronic device shown in Fig. 8 is only an example and should not bring any limitation to the functions and scope of use of the embodiments of the present disclosure.
  • the electronic device is presented in the form of a general-purpose computing device.
  • the components of the electronic device may include, but are not limited to: one or more processors or processing units 16, a system memory 28, and a computer that connects different system components (including the system memory 28 and the processing unit 16).
  • Bus 18 the bus 18.
  • Bus 18 represents one or more of several types of bus structures, including a memory bus or memory controller, a peripheral bus, a graphics acceleration port, a processor or a local bus using any of a variety of bus structures.
  • these architectures include but are not limited to Industry Standard Architecture (hereinafter referred to as: ISA) bus, Micro Channel Architecture (hereinafter referred to as: MAC) bus, Enhanced ISA bus, Video Electronics Standards Association (hereinafter referred to as: VESA) local bus and Peripheral Component Interconnection (hereinafter referred to as: PCI) bus.
  • ISA Industry Standard Architecture
  • MAC Micro Channel Architecture
  • VESA Video Electronics Standards Association
  • PCI Peripheral Component Interconnection
  • Electronic devices typically include a variety of computer system readable media. These media can be any available media that can be accessed by the electronic device, including volatile and non-volatile media, removable and non-removable media.
  • the memory 28 may include computer system readable media in the form of volatile memory, such as random access memory (RAM) 30 and/or cache memory 32.
  • RAM random access memory
  • the electronic device may further include other removable/non-removable, volatile/non-volatile computer system storage media.
  • the storage system 34 may be used to read and write non-removable, non-volatile magnetic media (not shown in FIG. 8 , commonly referred to as a “hard drive”).
  • a disk drive for reading and writing a removable nonvolatile disk e.g., a “floppy disk”
  • an optical disk drive for reading and writing a removable nonvolatile optical disk
  • each drive may be connected to the bus 18 via one or more data medium interfaces.
  • the memory 28 may include at least one program product having a set (e.g., at least one) of program modules configured to perform the functions of the various embodiments of the present disclosure.
  • a program/utility 40 having a set (at least one) of program modules 42 may be stored, for example, in the memory 28, such program modules 42 including but not limited to an operating system, one or more application programs, other program modules, and program data, each of which or some combination may include an implementation of a network environment.
  • the program modules 42 generally perform the functions and/or methods of the embodiments described in the present disclosure.
  • the electronic device may also communicate with one or more external devices 14 (e.g., keyboard, pointing device, display 24, etc.), may also communicate with one or more devices that enable a user to interact with the electronic device, and/or communicate with any device that enables the electronic device to communicate with one or more other computing devices (e.g., network card, modem, etc.). Such communication may be performed through an input/output (I/O) interface 22.
  • the electronic device may also communicate with one or more networks (e.g., a local area network (LAN), a wide area network (WAN), and/or a public network, such as the Internet) through a network adapter 20. As shown, the network adapter 20 communicates with other modules of the electronic device through a bus 18.
  • LAN local area network
  • WAN wide area network
  • public network such as the Internet
  • the processing unit 16 executes various functional applications and data processing by running the programs stored in the system memory 28, such as implementing the data processing method for medical equipment mentioned in the above embodiments.
  • Any process or method description in a flowchart or otherwise described herein may be understood to represent a module, segment or portion of code that includes one or more executable instructions for implementing the steps of a specific logical function or process, and the scope of the preferred embodiments of the present disclosure includes alternative implementations in which functions may not be performed in the order shown or discussed, including performing functions in a substantially simultaneous manner or in the reverse order depending on the functions involved, which should be understood by those skilled in the art to which the embodiments of the present disclosure belong.
  • each functional unit in each embodiment of the present disclosure can be integrated into a processing unit.
  • each unit may exist physically separately, or two or more units may be integrated into one module.
  • the above-mentioned integrated module may be implemented in the form of hardware or in the form of a software functional module. If the integrated module is implemented in the form of a software functional module and sold or used as an independent product, it may also be stored in a computer-readable storage medium.
  • the storage medium mentioned above can be a read-only memory, a magnetic disk or an optical disk, etc.

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • Health & Medical Sciences (AREA)
  • General Physics & Mathematics (AREA)
  • Biomedical Technology (AREA)
  • Software Systems (AREA)
  • Data Mining & Analysis (AREA)
  • Databases & Information Systems (AREA)
  • General Engineering & Computer Science (AREA)
  • Epidemiology (AREA)
  • Mathematical Physics (AREA)
  • Fuzzy Systems (AREA)
  • Computational Linguistics (AREA)
  • Business, Economics & Management (AREA)
  • General Business, Economics & Management (AREA)
  • Probability & Statistics with Applications (AREA)
  • General Health & Medical Sciences (AREA)
  • Medical Informatics (AREA)
  • Primary Health Care (AREA)
  • Public Health (AREA)
  • Medical Treatment And Welfare Office Work (AREA)
  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

A data processing method and apparatus for a medical device, an electronic device, and a storage medium. The method is executed by a distributed processing engine, and comprises: acquiring data to be processed and a device identifier, wherein the device identifier is used for identifying a medical device to which said data belongs; and when a target data processing engine matching the device identifier is found from a plurality of initial data processing engines pre-stored in a local database, sending said data to the target data processing engine, wherein the target data processing engine at least comprises a debugged data processing script corresponding to the device identifier, and the data processing script is used for processing said data.

Description

用于医疗设备的数据处理方法、装置、电子设备及介质Data processing method, device, electronic device and medium for medical equipment

相关申请的交叉引用CROSS-REFERENCE TO RELATED APPLICATIONS

本公开要求享有2023年3月3日提交的申请号为202310207537.4的中国发明专利申请的优先权,其全部内容通过引用并入本文。The present disclosure claims priority to the Chinese invention patent application No. 202310207537.4 filed on March 3, 2023, the entire contents of which are incorporated herein by reference.

技术领域Technical Field

本公开涉及医疗健康技术领域,尤其涉及一种用于医疗设备的数据处理方法、装置、电子设备及存储介质。The present disclosure relates to the field of medical health technology, and in particular to a data processing method, device, electronic device and storage medium for medical equipment.

背景技术Background Art

在以数据驱动医疗健康的时代,作为主要数据接口之一的医疗设备(例如,可穿戴医疗设备)正越来越受到重视,医疗设备可以通过采集人体的各项生理指标数据,再对医疗设备采集得到的生理指标数据进行处理,得到数据处理结果,而后可以对数据处理结果进行分析,以获取具有相关医学意义的信息。In the era of data-driven healthcare, medical devices (for example, wearable medical devices) as one of the main data interfaces are receiving more and more attention. Medical devices can collect various physiological index data of the human body, process the physiological index data collected by the medical devices, obtain data processing results, and then analyze the data processing results to obtain information with relevant medical significance.

相关技术中,通常是在采集到医疗设备的相关待处理数据之后,编译与该待处理数据对应的数据处理脚本,而后可以基于该数据处理脚本对待处理数据进行处理。In the related art, usually after collecting the relevant data to be processed of the medical device, a data processing script corresponding to the data to be processed is compiled, and then the data to be processed can be processed based on the data processing script.

这种方式下,每当在编译新的数据处理脚本对待处理数据进行处理时,就需要重复引入对数据处理脚本的开发,联调,测试,上线等一系列流程,从而会导致数据处理的操作流程较为繁琐。In this way, every time a new data processing script is compiled to process the data to be processed, a series of processes such as development, joint debugging, testing, and online release of the data processing script need to be repeatedly introduced, which will make the data processing operation process more cumbersome.

发明内容Summary of the invention

本公开旨在至少在一定程度上解决相关技术中的技术问题之一。The present disclosure aims to solve one of the technical problems in the related art at least to some extent.

为此,本公开的目的在于提出一种用于医疗设备的数据处理方法、装置、电子设备及存储介质。 To this end, the purpose of the present disclosure is to provide a data processing method, device, electronic device and storage medium for medical equipment.

本公开的一个方面的实施例提出的用于医疗设备的数据处理方法,被分布式处理引擎执行,方法包括:获取待处理数据和设备标识,其中,设备标识用于标识待处理数据所属医疗设备;如果从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎,则将待处理数据发送至目标数据处理引擎,其中,目标数据处理引擎至少包括:已调试的与设备标识对应的数据处理脚本,数据处理脚本用于处理待处理数据。An embodiment of one aspect of the present disclosure proposes a data processing method for medical devices, which is executed by a distributed processing engine, and includes: obtaining data to be processed and a device identifier, wherein the device identifier is used to identify the medical device to which the data to be processed belongs; if a target data processing engine matching the device identifier is found from multiple initial data processing engines pre-stored in a local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine includes at least: a debugged data processing script corresponding to the device identifier, and the data processing script is used to process the data to be processed.

本公开的另一个方面的实施例提出的用于医疗设备的数据处理方法,被目标数据处理引擎执行,目标数据处理引擎至少包括:数据处理脚本,方法包括:接收分布式处理引擎发送的医疗设备的待处理数据,其中,待处理数据所属医疗设备具有设备标识;根据数据处理脚本处理待处理数据,其中,数据处理脚本与设备标识相对应。An embodiment of another aspect of the present disclosure proposes a data processing method for medical devices, which is executed by a target data processing engine, and the target data processing engine at least includes: a data processing script, and the method includes: receiving data to be processed from a medical device sent by a distributed processing engine, wherein the medical device to which the data to be processed belongs has a device identification; processing the data to be processed according to the data processing script, wherein the data processing script corresponds to the device identification.

本公开的再一个方面的实施例提出的用于医疗设备的数据处理装置,被分布式处理引擎执行,装置包括:获取模块,用于获取待处理数据和设备标识,其中,设备标识用于标识待处理数据所属医疗设备;发送模块,用于在从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎时,将待处理数据发送至目标数据处理引擎,其中,目标数据处理引擎至少包括:已调试的与设备标识对应的数据处理脚本,数据处理脚本用于处理待处理数据。An embodiment of another aspect of the present disclosure proposes a data processing device for medical equipment, which is executed by a distributed processing engine, and the device includes: an acquisition module, used to acquire data to be processed and a device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs; a sending module, used to send the data to be processed to the target data processing engine when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in a local database, wherein the target data processing engine includes at least: a debugged data processing script corresponding to the device identification, and the data processing script is used to process the data to be processed.

本公开的再一个方面的实施例提出的用于医疗设备的数据处理装置,目标数据处理引擎至少包括:数据处理脚本,装置包括:接收模块,用于接收分布式处理引擎发送的医疗设备的待处理数据,其中,待处理数据所属医疗设备具有设备标识;处理模块,用于根据数据处理脚本处理待处理数据,其中,数据处理脚本与设备标识相对应。 An embodiment of another aspect of the present disclosure proposes a data processing device for medical equipment, wherein the target data processing engine at least includes: a data processing script, and the device includes: a receiving module for receiving the data to be processed of the medical equipment sent by the distributed processing engine, wherein the medical equipment to which the data to be processed belongs has a device identification; and a processing module for processing the data to be processed according to the data processing script, wherein the data processing script corresponds to the device identification.

本公开的再一个方面的实施例提出了一种电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,处理器执行程序时,实现如本公开第一方面实施例提出的用于医疗设备的数据处理方法,或者实现如本公开第二方面实施例提出的用于医疗设备的数据处理方法。An embodiment of another aspect of the present disclosure provides an electronic device, comprising a memory, a processor, and a computer program stored in the memory and executable on the processor. When the processor executes the program, it implements the data processing method for a medical device as proposed in the embodiment of the first aspect of the present disclosure, or implements the data processing method for a medical device as proposed in the embodiment of the second aspect of the present disclosure.

本公开的再一个方面的实施例提出了一种非临时性计算机可读存储介质,其上存储有计算机程序,该程序被处理器执行时实现如本公开第一方面实施例提出的用于医疗设备的数据处理方法,或者实现如本公开第二方面实施例提出的用于医疗设备的数据处理方法。An embodiment of another aspect of the present disclosure proposes a non-temporary computer-readable storage medium having a computer program stored thereon, which, when executed by a processor, implements the data processing method for a medical device as proposed in the embodiment of the first aspect of the present disclosure, or implements the data processing method for a medical device as proposed in the embodiment of the second aspect of the present disclosure.

本公开的再一个方面的实施例提出了一种计算机程序产品,当计算机程序产品中的指令处理器执行时,执行如本公开第一方面实施例提出的用于医疗设备的数据处理方法,或者实现如本公开第二方面实施例提出的用于医疗设备的数据处理方法。An embodiment of another aspect of the present disclosure proposes a computer program product. When an instruction processor in the computer program product executes, it executes the data processing method for a medical device as proposed in the embodiment of the first aspect of the present disclosure, or implements the data processing method for a medical device as proposed in the embodiment of the second aspect of the present disclosure.

本公开附加的方面和优点将在下面的描述中部分给出,部分将从下面的描述中变得明显,或通过本公开的实践了解到。Additional aspects and advantages of the present disclosure will be given in part in the following description and in part will be obvious from the following description or learned through practice of the present disclosure.

附图说明BRIEF DESCRIPTION OF THE DRAWINGS

本公开上述的和/或附加的方面和优点从下面结合附图对实施例的描述中将变得明显和容易理解,其中:The above and/or additional aspects and advantages of the present disclosure will become apparent and easily understood from the following description of the embodiments in conjunction with the accompanying drawings, in which:

图1是本公开一实施例提出的用于医疗设备的数据处理方法的流程示意图;FIG1 is a flow chart of a data processing method for medical equipment according to an embodiment of the present disclosure;

图2是本公开一实施例提出的待处理数据传输的流程示意图;FIG2 is a schematic diagram of a process flow of data transmission to be processed proposed in an embodiment of the present disclosure;

图3是本公开另一实施例提出的用于医疗设备的数据处理方法的流程示意图;FIG3 is a flow chart of a data processing method for medical equipment according to another embodiment of the present disclosure;

图4是本公开另一实施例提出的用于医疗设备的数据处理方法的流程示意图;FIG4 is a flow chart of a data processing method for medical equipment according to another embodiment of the present disclosure;

图5是本公开一实施例提出的用于医疗设备的数据处理方法的流 程示意图;FIG. 5 is a flowchart of a data processing method for medical equipment according to an embodiment of the present disclosure. Process diagram;

图6是本公开一实施例提出的用于医疗设备的数据处理装置的结构示意图;FIG6 is a schematic diagram of the structure of a data processing device for medical equipment according to an embodiment of the present disclosure;

图7是本公开一实施例提出的用于医疗设备的数据处理装置的结构示意图;FIG7 is a schematic diagram of the structure of a data processing device for medical equipment proposed in an embodiment of the present disclosure;

图8示出了适于用来实现本公开实施方式的示例性电子设备的框图。FIG8 shows a block diagram of an exemplary electronic device suitable for implementing embodiments of the present disclosure.

具体实施方式DETAILED DESCRIPTION

下面详细描述本公开的实施例,实施例的示例在附图中示出,其中自始至终相同或类似的标号表示相同或类似的元件或具有相同或类似功能的元件。下面通过参考附图描述的实施例是示例性的,仅用于解释本公开,而不能理解为对本公开的限制。相反,本公开的实施例包括落入所附加权利要求书的精神和内涵范围内的所有变化、修改和等同物。Embodiments of the present disclosure are described in detail below, and examples of the embodiments are shown in the accompanying drawings, wherein the same or similar reference numerals throughout represent the same or similar elements or elements having the same or similar functions. The embodiments described below with reference to the accompanying drawings are exemplary and are only used to explain the present disclosure, and should not be construed as limitations on the present disclosure. On the contrary, the embodiments of the present disclosure include all changes, modifications, and equivalents that fall within the spirit and connotation of the appended claims.

需要说明的是,本公开技术方案中对数据的获取、采集、存储、使用、处理等,其过程均符合相关法律、法规的规定,且不违背公序良俗。It should be noted that the processes of data acquisition, collection, storage, use, and processing in the technical solution disclosed in this disclosure comply with the provisions of relevant laws and regulations and do not violate public order and good morals.

图1是本公开一实施例提出的用于医疗设备的数据处理方法的流程示意图。FIG1 is a flow chart of a data processing method for medical equipment proposed in an embodiment of the present disclosure.

其中,需要说明的是,本实施例的用于医疗设备的数据处理方法的执行主体为用于医疗设备的数据处理装置,该装置可以由软件和/或硬件的方式实现,该装置可以配置在电子设备中,电子设备可以包括但不限于终端、服务器端等。It should be noted that the executor of the data processing method for medical equipment in this embodiment is a data processing device for medical equipment, which can be implemented by software and/or hardware. The device can be configured in an electronic device, and the electronic device may include but is not limited to a terminal, a server, etc.

如图1所示,该用于医疗设备的数据处理方法,被分布式处理引擎执行,该分布式处理引擎可以具体例如是Flink,对此不做限制。 As shown in FIG. 1 , the data processing method for medical equipment is executed by a distributed processing engine, and the distributed processing engine may be, for example, Flink, without limitation.

S101:获取待处理数据和设备标识,设备标识用于标识待处理数据所属医疗设备。S101: Acquire data to be processed and a device identifier, where the device identifier is used to identify the medical device to which the data to be processed belongs.

其中,医疗设备可以具体例如是可穿戴医疗设备,该医疗设备可以具体例如为智能血压仪、智能血糖仪等,对此不做限制。The medical device may specifically be a wearable medical device, and the medical device may specifically be a smart blood pressure meter, a smart blood glucose meter, etc., without limitation.

本公开实施例描述的用于医疗设备的数据处理方法可以用于对医疗设备的相关数据进行处理,该相关数据可以具体例如是医疗设备针对用户监测到的人体指标数据(例如,血压数据,血糖数据,对此不做限制)。The data processing method for medical equipment described in the embodiments of the present disclosure can be used to process relevant data of the medical equipment, and the relevant data can specifically be, for example, human body indicator data monitored by the medical equipment for the user (for example, blood pressure data, blood sugar data, without limitation).

其中,设备标识可以用于标识唯一医疗设备,该设备标识可以例如是医疗设备的名称,医疗设备的编号等,对此不做限制。The device identifier may be used to identify a unique medical device, and the device identifier may be, for example, the name of the medical device, the serial number of the medical device, etc., without limitation.

一些实施例中,获取待处理数据和设备标识,可以是预先构建医疗设备和Flink之间的数据传输链路,而后Flink可以基于医疗设备和Flink之间的数据传输链路,获取医疗设备的相关指标数据作为待处理数据,并获取医疗设备的设备编号作为设备标识,对此不做限制。In some embodiments, obtaining the data to be processed and the device identification can be to pre-build a data transmission link between the medical device and Flink, and then Flink can obtain the relevant indicator data of the medical device as the data to be processed based on the data transmission link between the medical device and Flink, and obtain the device number of the medical device as the device identification, without limitation.

本公开实施例中,参见图2,图2是本公开一实施例提出的待处理数据传输的流程示意图,如图2所示,获取待处理数据和设备标识可以是由MQTT Cluster对医疗设备进行监听,并在监听到医疗设备产生待处理数据时,将待处理数据和设备标识上报至MQTT Cluster中的MQTT Broker中,MQTT Broker插件中预先可以集成有与Kafka Client中的Kafka Topic映射规则,从而在获取到医疗设备上报的待处理数据和设备标识后,可以将待处理数据和设备标识映射至Kafka Client中的Kafka Topic中,而后,Flink可以从Kafka Topic中获取得到相应的待处理数据和设备标识。 In an embodiment of the present disclosure, refer to Figure 2, which is a flow chart of the transmission of pending data proposed in an embodiment of the present disclosure. As shown in Figure 2, the data to be processed and the device identification can be obtained by the MQTT Cluster monitoring the medical device, and when the medical device generates the data to be processed, the data to be processed and the device identification are reported to the MQTT Broker in the MQTT Cluster. The MQTT Broker plug-in can be pre-integrated with the Kafka Topic mapping rules in the Kafka Client, so that after obtaining the data to be processed and the device identification reported by the medical device, the data to be processed and the device identification can be mapped to the Kafka Topic in the Kafka Client, and then Flink can obtain the corresponding data to be processed and the device identification from the Kafka Topic.

S102:如果从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎,则将待处理数据发送至目标数据处理引擎。S102: If a target data processing engine matching the device identifier is found from a plurality of initial data processing engines pre-stored in the local database, the data to be processed is sent to the target data processing engine.

其中,目标数据处理引擎至少包括:已调试的与设备标识对应的数据处理脚本(该数据处理脚本可以具体例如为(Java Script,JS)脚本。Among them, the target data processing engine at least includes: a debugged data processing script corresponding to the device identifier (the data processing script can be specifically, for example, a (Java Script, JS) script.

其中,初始数据处理引擎是分布式处理引擎所属平台的本地数据库中预先存储的用于基于数据处理脚本处理待处理数据的脚本引擎,该初始数据处理引擎可以具体例如为JS引擎(JS引擎的主要功能,就是结合JS脚本的特性来编译执行脚本),而目标数据处理引擎是初始数据处理引擎中与待处理数据相适配的初始数据处理引擎,该目标数据处理引擎可以基于数据处理脚本处理待处理数据。Among them, the initial data processing engine is a script engine pre-stored in the local database of the platform to which the distributed processing engine belongs, and is used to process the data to be processed based on the data processing script. The initial data processing engine can be specifically, for example, a JS engine (the main function of the JS engine is to compile and execute scripts in combination with the characteristics of the JS script), and the target data processing engine is the initial data processing engine in the initial data processing engine that is adapted to the data to be processed. The target data processing engine can process the data to be processed based on the data processing script.

可以理解的是,在基于数据处理脚本处理待处理数据的过程中,通常需要引入对数据处理脚本的开发,联调,测试,上线等一系列流程,从而会导致数据处理流程较为繁琐,而调试完成的数据处理脚本可以直接用于处理待处理数据,从而有效地简化数据处理的操作流程。It is understandable that in the process of processing the data to be processed based on the data processing script, it is usually necessary to introduce a series of processes such as development, joint debugging, testing, and online release of the data processing script, which will make the data processing process more cumbersome. The debugged data processing script can be directly used to process the data to be processed, thereby effectively simplifying the data processing operation process.

也即是说,本公开实施例中,在获取待处理数据和设备标识之后,可以在分布式处理引擎所属平台的本地数据库中查找是否存在与设备标识对应的目标数据处理引擎,并在从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎时,将待处理数据发送至目标数据处理引擎,而后,目标数据处理引擎可以基于编译执行数据处理脚本实现对待处理数据进行处理。That is to say, in the embodiment of the present disclosure, after obtaining the data to be processed and the device identification, it is possible to search whether there is a target data processing engine corresponding to the device identification in the local database of the platform to which the distributed processing engine belongs, and when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in the local database, the data to be processed is sent to the target data processing engine, and then, the target data processing engine can process the data to be processed based on compiling and executing the data processing script.

本公开实施例中,在确定与设备标识对应的目标数据处理引擎之后,可以将待处理数据发送至目标数据处理引擎,而后,目标数据处理引擎可以基于数据处理脚本对待处理数据进行处理,以实现本公开 实施例描述的用于医疗设备的数据处理方法,具体可以参见后续实施例,在此不再赘述。In the embodiment of the present disclosure, after determining the target data processing engine corresponding to the device identifier, the data to be processed can be sent to the target data processing engine, and then the target data processing engine can process the data to be processed based on the data processing script to implement the present disclosure. The data processing method for medical equipment described in the embodiment can be specifically referred to in the subsequent embodiments, which will not be described in detail here.

本公开实施例中,通过获取待处理数据和设备标识,其中,设备标识用于标识待处理数据所属医疗设备,并在从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎时,将待处理数据发送至目标数据处理引擎,其中,目标数据处理引擎至少包括:已调试的与设备标识对应的数据处理脚本,数据处理脚本用于处理待处理数据,通过本公开,能够基于设备标识直接匹配到用于对待处理数据进行处理的目标数据处理引擎,且由于数据处理引擎中包含预先调试完成的与设备标识对应的数据处理脚本,从而无需重复引入数据处理脚本的开发,联调,测试,上线等一系列调试流程,进而在将待处理数据发送至目标数据处理引擎时,目标数据处理引擎能够直接基于编译数据处理脚本完成对待处理数据的处理,从而能够有效地简化数据处理的操作流程。In an embodiment of the present disclosure, by obtaining the data to be processed and the device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs, and when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in a local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identification, and the data processing script is used to process the data to be processed. Through the present disclosure, it is possible to directly match the target data processing engine used to process the data to be processed based on the device identification, and because the data processing engine contains a pre-debugged data processing script corresponding to the device identification, there is no need to repeatedly introduce a series of debugging processes such as development, joint debugging, testing, and online release of the data processing script, and then when the data to be processed is sent to the target data processing engine, the target data processing engine can directly complete the processing of the data to be processed based on the compiled data processing script, thereby effectively simplifying the data processing operation process.

图3是本公开另一实施例提出的用于医疗设备的数据处理方法的流程示意图。FIG3 is a flow chart of a data processing method for medical equipment proposed in another embodiment of the present disclosure.

如图3所示,该用于医疗设备的数据处理方法,包括:As shown in FIG3 , the data processing method for medical equipment includes:

S301:在医疗设备在分布式处理引擎所属平台注册的情况下,获取每个医疗设备的候选设备标识。S301: When the medical device is registered on the platform to which the distributed processing engine belongs, a candidate device identification of each medical device is obtained.

本公开实施例中,可以是在引入某一医疗设备时,将医疗设备在分布式处理引擎所属的平台上进行注册,以获取每个医疗设备的候选设备标识。In the disclosed embodiment, when a certain medical device is introduced, the medical device may be registered on the platform to which the distributed processing engine belongs to obtain a candidate device identification of each medical device.

S302:获取与每个候选设备标识对应的候选处理脚本。S302: Obtain a candidate processing script corresponding to each candidate device identifier.

其中,候选处理脚本可以用于对相应候选标识所标识的医疗设备 的数据进行处理。The candidate processing script can be used to process the medical device identified by the corresponding candidate identifier. data to be processed.

本公开实施例在获取每个医疗设备的候选设备标识后,可以针对每个候选设备标识编译相应的候选处理脚本,而后,可以基于候选处理脚本触发执行后续的用于医疗设备的数据处理方法,对此不做限制。After obtaining the candidate device identification of each medical device, the embodiment of the present disclosure can compile a corresponding candidate processing script for each candidate device identification, and then trigger the execution of subsequent data processing methods for the medical device based on the candidate processing script, without limitation.

S303:将候选处理脚本存储至云端数据库中。S303: Storing the candidate processing scripts in a cloud database.

本公开实施例在获取与每个候选设备标识对应的候选处理脚本后,可以将候选处理脚本存储在云端数据库中,而后,可以在后续的用于医疗设备的数据处理方法的执行过程中,支持从云端数据库中快速调用预先存储的候选处理脚本。After obtaining the candidate processing script corresponding to each candidate device identifier, the embodiment of the present disclosure can store the candidate processing script in a cloud database, and then, in the subsequent execution of the data processing method for the medical device, support the rapid call of the pre-stored candidate processing script from the cloud database.

S304:确定每个候选处理脚本在云端数据库中的存储地址。S304: Determine the storage address of each candidate processing script in the cloud database.

其中,候选处理脚本在云端数据库中的存储地址可以例如是,候选处理脚本在云端数据库中的资源定位符,对此不做限制。The storage address of the candidate processing script in the cloud database may be, for example, a resource locator of the candidate processing script in the cloud database, and there is no limitation on this.

也即是说,本公开实施例在将候选处理脚本存储在云端数据库中之后,可以确定每个候选处理脚本在云端数据库中的资源定位符作为存储地址。That is, after storing the candidate processing scripts in the cloud database, the embodiment of the present disclosure may determine the resource locator of each candidate processing script in the cloud database as the storage address.

S305:将存储地址存储至分布式处理引擎所属平台的本地数据库中。S305: Store the storage address in the local database of the platform to which the distributed processing engine belongs.

本公开实施例在确定每个候选处理脚本在云端数据库中的存储地址后,可以将存储地址存储至分布式处理引擎所属平台的本地数据库中。After determining the storage address of each candidate processing script in the cloud database, the embodiment of the present disclosure may store the storage address in the local database of the platform to which the distributed processing engine belongs.

S306:为本地数据库中存储的存储地址分配索引项。 S306: Allocate index items to the storage addresses stored in the local database.

其中,索引项可以用于从本地数据库中索引得到相应的存储地址。The index item can be used to obtain the corresponding storage address from the local database.

本公开实施例中,通过确定每个候选处理脚本在云端数据库中的存储地址,并将存储地址存储至分布式处理引擎所属平台的本地数据库中,再为本地数据库中存储的存储地址分配索引项,由于是将候选处理脚本在云端数据库中的存储地址存储在本地数据库中,从而能够有效地节约本地数据库的存储资源,再通过为本地数据库中存储的存储地址分配索引项,从而能够便利从本地数据库中获取存储地址。In the disclosed embodiment, by determining the storage address of each candidate processing script in the cloud database, and storing the storage address in the local database of the platform to which the distributed processing engine belongs, and then assigning an index item to the storage address stored in the local database, since the storage address of the candidate processing script in the cloud database is stored in the local database, the storage resources of the local database can be effectively saved, and by assigning an index item to the storage address stored in the local database, the storage address can be conveniently obtained from the local database.

一些实施例中,为本地数据库中存储的存储地址分配索引项,可以是将存储地址的末位字符作为本地数据库中存储的存储地址的索引项,对此不做限制。In some embodiments, assigning an index item to a storage address stored in a local database may be performed by using the last character of the storage address as the index item of the storage address stored in the local database, and there is no limitation to this.

举例而言,假设存储地址是“asdgjfkl111”则为本地数据库中存储的存储地址分配索引项,可以是将末位字符“1”作为存储地址“asdgjfkl111”在本地数据库中的索引项,对此不做限制。For example, assuming the storage address is "asdgjfkl111", an index item is assigned to the storage address stored in the local database. The last character "1" can be used as the index item of the storage address "asdgjfkl111" in the local database. There is no limitation on this.

可选地,一些实施例中,为本地数据库中存储的存储地址分配索引项,可以是将候选设备标识配置为本地数据库中存储的存储地址的索引项,而后,可以在用于医疗设备的数据处理方法的执行过程中,根据设备标识准确地调用与该设备标识对应的候选处理脚本的存储地址。Optionally, in some embodiments, assigning an index item to a storage address stored in a local database may be accomplished by configuring a candidate device identifier as an index item of a storage address stored in the local database, and then, during the execution of a data processing method for a medical device, the storage address of a candidate processing script corresponding to the device identifier may be accurately called according to the device identifier.

S307:获取待处理数据和设备标识,其中,设备标识用于标识待处理数据所属医疗设备。S307: Acquire the data to be processed and the device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs.

S308:如果从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎,则将待处理数据发送至目标数据处理引擎。 S308: If a target data processing engine matching the device identifier is found from a plurality of initial data processing engines pre-stored in the local database, the data to be processed is sent to the target data processing engine.

S308的描述说明具体可以参见上述实施例,在此不再赘述。The specific description of S308 can be found in the above embodiment, which will not be repeated here.

本公开实施例中,通过在医疗设备在分布式处理引擎所属平台注册的情况下,获取每个医疗设备的候选设备标识,并获取与每个候选设备标识对应的候选处理脚本,再将候选处理脚本存储至云端数据库中,而后,可以在后续的用于医疗设备的数据处理方法的执行过程中,支持从云端数据库中快速调用预先存储的候选处理脚本,并确定每个候选处理脚本在云端数据库中的存储地址,并将存储地址存储至分布式处理引擎所属平台的本地数据库中,再为本地数据库中存储的存储地址分配索引项,由于是将候选处理脚本在云端数据库中的存储地址存储在本地数据库中,从而能够有效地节约本地数据库的存储资源,再通过为本地数据库中存储的存储地址分配索引项,从而能够便利从本地数据库中获取存储地址,再获取待处理数据和设备标识,设备标识用于标识待处理数据所属医疗设备,并在从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎时,将待处理数据发送至目标数据处理引擎,其中,目标数据处理引擎至少包括:已调试的与设备标识对应的数据处理脚本,数据处理脚本用于处理待处理数据,由于数据处理引擎中包含预先调试完成的与设备标识对应的数据处理脚本,从而无需重复引入数据处理脚本的开发,联调,测试,上线等一系列调试流程,进而在将待处理数据发送至目标数据处理引擎时,目标数据处理引擎能够直接基于编译数据处理脚本完成对待处理数据的处理,从而能够有效地简化数据处理的操作流程。In the embodiment of the present disclosure, by obtaining the candidate device identification of each medical device when the medical device is registered on the platform to which the distributed processing engine belongs, and obtaining the candidate processing script corresponding to each candidate device identification, and then storing the candidate processing script in the cloud database, it is possible to support the rapid call of pre-stored candidate processing scripts from the cloud database in the subsequent execution process of the data processing method for the medical device, determine the storage address of each candidate processing script in the cloud database, store the storage address in the local database of the platform to which the distributed processing engine belongs, and then assign index items to the storage addresses stored in the local database. Since the storage addresses of the candidate processing scripts in the cloud database are stored in the local database, the storage resources of the local database can be effectively saved. By assigning index items to the storage addresses stored in the local database, it is possible to facilitate the call from the local database to the local database. The storage address is obtained from the database, and then the data to be processed and the device identification are obtained, the device identification is used to identify the medical device to which the data to be processed belongs, and when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in the local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identification, the data processing script is used to process the data to be processed, and since the data processing engine contains a pre-debugged data processing script corresponding to the device identification, there is no need to repeatedly introduce a series of debugging processes such as development, joint debugging, testing, and online launch of the data processing script, and then when the data to be processed is sent to the target data processing engine, the target data processing engine can directly complete the processing of the data to be processed based on the compiled data processing script, thereby effectively simplifying the data processing operation process.

图4是本公开另一实施例提出的用于医疗设备的数据处理方法的流程示意图。FIG. 4 is a flow chart of a data processing method for medical equipment proposed in another embodiment of the present disclosure.

如图4所示,该用于医疗设备的数据处理方法,包括:As shown in FIG4 , the data processing method for medical equipment includes:

S401:获取待处理数据和设备标识,其中,设备标识用于标识待 处理数据所属医疗设备。S401: Obtain the data to be processed and the device identification, wherein the device identification is used to identify the data to be processed. The medical device that processes the data.

S401的描述说明具体可以参加上述实施例,在此不再赘述。The specific description of S401 can be found in the above embodiment and will not be repeated here.

S402:如果从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎,则基于数据处理脚本构建目标数据处理引擎。S402: If a target data processing engine matching the device identifier is found from a plurality of initial data processing engines pre-stored in the local database, the target data processing engine is constructed based on the data processing script.

也即是说,本公开实施例中,在获取待处理数据和设备标识之后,可以在分布式处理引擎所属平台的本地数据库中查找是否存在与设备标识对应的目标数据处理引擎,并在从本地数据库中预先存储的多个初始数据处理引擎中未查找到与设备标识相匹配的目标数据处理引擎时,基于数据处理脚本构建目标数据处理引擎,而后,目标数据处理引擎可以基于编译执行数据处理脚本实现对待处理数据进行处理。That is to say, in the embodiment of the present disclosure, after obtaining the data to be processed and the device identification, it is possible to search whether there is a target data processing engine corresponding to the device identification in the local database of the platform to which the distributed processing engine belongs, and when the target data processing engine that matches the device identification is not found from the multiple initial data processing engines pre-stored in the local database, the target data processing engine is constructed based on the data processing script, and then, the target data processing engine can process the data to be processed based on compiling and executing the data processing script.

可选地,一些实施例中,在基于数据处理脚本构建数据处理引擎之前,还可以从本地数据库中多个索引项中确定与设备标识对应的目标索引项,其中,每个索引项用于索引一个存储地址,并基于目标索引项从本地数据库中索引所得的存储地址,再根据索引所得的存储地址,从云端数据库中存储的多个候选处理脚本中确定数据处理脚本。Optionally, in some embodiments, before building a data processing engine based on the data processing script, a target index item corresponding to the device identifier can also be determined from multiple index items in the local database, wherein each index item is used to index a storage address, and based on the storage address indexed from the local database by the target index item, the data processing script is determined from multiple candidate processing scripts stored in the cloud database based on the storage address obtained by the index.

其中,本地数据库中多个索引项中确定与设备标识对应的索引项,即可以被称为目标索引项。The index item corresponding to the device identifier determined from among the multiple index items in the local database may be referred to as the target index item.

也即是说,本公开实施例中,可以是从本地数据库中确定与设备标识对应的目标索引项,而后可以基于目标索引项从本地数据库中索引所得的存储地址,再根据索引所得的存储地址,从云端数据库中存储的多个候选处理脚本中确定数据处理脚本,由此,可以保障获取得到的数据处理脚本可以与设备标识相匹配,从而能够在后续的用于医疗设备的处理方法的执行过程中,确保构建得到的数据处理引擎能够 支持对相应设备标识的数据进行处理。That is to say, in the embodiment of the present disclosure, the target index item corresponding to the device identifier can be determined from the local database, and then the storage address obtained by indexing from the local database based on the target index item can be used to determine the data processing script from multiple candidate processing scripts stored in the cloud database according to the storage address obtained by indexing. In this way, it can be ensured that the acquired data processing script can match the device identifier, so that in the subsequent execution process of the processing method for the medical device, it can be ensured that the constructed data processing engine can Supports processing of data identified by corresponding devices.

可选地,一些实施例中,从本地数据库的多个索引项中确定与设备标识对应的目标索引项,可以是从本地数据库中,确定多个候选设备标识,并确定多个候选设备标识中与设备标识相同候选设备标识,再将相同候选设备标识作为目标索引项。Optionally, in some embodiments, a target index item corresponding to a device identifier is determined from multiple index items in a local database. This may be by determining multiple candidate device identifiers from the local database, and determining a candidate device identifier that is identical to the device identifier among the multiple candidate device identifiers, and then using the identical candidate device identifier as the target index item.

也即是说,本公开实施例中,可以是在获取得到相应的设备标识后,从本地数据库中存储的多个候选设备标识中,确定与该设备标识相同的候选设备标识,并将与设备标识相同候选设备标识,作为目标索引项,而后可以基于目标索引项从本地数据库中索引所得的存储地址,再根据索引所得的存储地址,从云端数据库中存储的多个候选处理脚本中确定数据处理脚本。That is to say, in the embodiments of the present disclosure, after obtaining the corresponding device identifier, a candidate device identifier that is identical to the device identifier can be determined from multiple candidate device identifiers stored in the local database, and the candidate device identifier that is identical to the device identifier can be used as the target index item. Then, based on the target index item, a storage address can be indexed from the local database, and then, according to the storage address obtained by indexing, a data processing script can be determined from multiple candidate processing scripts stored in the cloud database.

S403:如果未从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎,则基于数据处理脚本构建目标数据处理引擎。S403: If a target data processing engine matching the device identifier is not found from the multiple initial data processing engines pre-stored in the local database, the target data processing engine is constructed based on the data processing script.

S403的描述说明具体可以参见上述实施例,在此不再赘述。The specific description of S403 can be found in the above embodiment, which will not be repeated here.

本公开实施例中,通过获取待处理数据和设备标识,其中,设备标识用于标识待处理数据所属医疗设备,并确定在本地数据库中查找数据处理引擎得到的查找结果,再根据查找结果,确定数据处理引擎的目标确定方式,并基于目标确定方式,确定与设备标识对应的数据处理引擎,由此,可以基于目标确定方式准确地确定与设备标识对应的数据处理引擎,再将待处理数据发送至数据处理引擎,由此,能够为待处理数据提供相适配的数据处理引擎,从而能够有效地简化数据处理操作流程,有效地提升数据处理效果。In the disclosed embodiment, by obtaining the data to be processed and the device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs, and determining the search result obtained by searching the data processing engine in the local database, and then determining the target determination method of the data processing engine based on the search result, and determining the data processing engine corresponding to the device identification based on the target determination method, thereby, the data processing engine corresponding to the device identification can be accurately determined based on the target determination method, and then the data to be processed is sent to the data processing engine, thereby, a suitable data processing engine can be provided for the data to be processed, thereby effectively simplifying the data processing operation process and effectively improving the data processing effect.

图5是本公开一实施例提出的用于医疗设备的数据处理方法的流 程示意图。FIG. 5 is a flowchart of a data processing method for medical equipment according to an embodiment of the present disclosure. Process diagram.

其中,需要说明的是,本实施例的用于医疗设备的数据处理方法的执行主体为用于医疗设备的数据处理装置,该装置可以由软件和/或硬件的方式实现,该装置可以配置在电子设备中,电子设备可以包括但不限于终端、服务器端等。It should be noted that the executor of the data processing method for medical equipment in this embodiment is a data processing device for medical equipment, which can be implemented by software and/or hardware. The device can be configured in an electronic device, and the electronic device may include but is not limited to a terminal, a server, etc.

如图5所示,该用于医疗设备的数据处理方法,被目标数据处理引擎执行,目标数据处理引擎至少包括:数据处理脚本,该目标数据处理引擎可以具体例如是JS引擎,相应地,该数据处理脚本可以具体例如是,JS脚本,对此不做限制。As shown in Figure 5, the data processing method for medical equipment is executed by a target data processing engine, which at least includes: a data processing script. The target data processing engine can be specifically, for example, a JS engine. Accordingly, the data processing script can be specifically, for example, a JS script, without limitation.

S501:接收分布式处理引擎发送的医疗设备的待处理数据,其中,待处理数据所属医疗设备具有设备标识。S501: Receive data to be processed of a medical device sent by a distributed processing engine, wherein the medical device to which the data to be processed belongs has a device identifier.

本实施例中与上述实施例中相同的术语的含义和描述说明,可以具体参见上述实施例,在此不再赘述。The meanings and descriptions of the terms in this embodiment that are the same as those in the above embodiments can be specifically referred to in the above embodiments and will not be repeated here.

本公开实施例中,接收分布式处理引擎发送的医疗设备的待处理数据,可以是经由分布式处理引擎和目标数据处理引擎之间的数据传输链路,接收分布式处理引擎发送的医疗设备的待处理数据,而后,可以由目标数据处理引擎对待处理数据进行处理,具体可以参见后续实施例,在此不再赘述。In the embodiment of the present disclosure, the data to be processed of the medical device sent by the distributed processing engine can be received via a data transmission link between the distributed processing engine and the target data processing engine. Then, the data to be processed can be processed by the target data processing engine. For details, please refer to the subsequent embodiments and will not be repeated here.

S502:根据数据处理脚本处理待处理数据,其中,数据处理脚本与设备标识相对应。S502: Process the data to be processed according to a data processing script, wherein the data processing script corresponds to the device identifier.

本公开实施例中,目标数据处理引擎在接收分布式处理引擎发送的医疗设备的待处理数据之后,可以根据数据处理脚本处理待处理数据。 In the embodiment of the present disclosure, after receiving the data to be processed of the medical device sent by the distributed processing engine, the target data processing engine can process the data to be processed according to the data processing script.

本实施例中,通过接收分布式处理引擎发送的医疗设备的待处理数据,其中,待处理数据所属医疗设备具有设备标识,并根据数据处理脚本处理待处理数据,其中,数据处理脚本与设备标识相对应,由此,可以使得数据处理脚本可以独立在目标数据处理引擎中编译,且能够支持多引擎之间独立运行,有效地避免同时处理多设备数据之间相互影响,有效地保障数据处理效果。In this embodiment, the data to be processed of the medical device sent by the distributed processing engine is received, wherein the medical device to which the data to be processed belongs has a device identification, and the data to be processed is processed according to the data processing script, wherein the data processing script corresponds to the device identification. Thus, the data processing script can be independently compiled in the target data processing engine, and can support independent operation between multiple engines, effectively avoiding mutual influence between the simultaneous processing of multiple device data, and effectively ensuring the data processing effect.

图6是本公开一实施例提出的用于医疗设备的数据处理装置的结构示意图。FIG6 is a schematic diagram of the structure of a data processing device for medical equipment proposed in an embodiment of the present disclosure.

如图6所示,该用于医疗设备的数据处理装置60,包括:As shown in FIG6 , the data processing device 60 for medical equipment includes:

获取模块601,用于获取待处理数据和设备标识,其中,设备标识用于标识待处理数据所属医疗设备;An acquisition module 601 is used to acquire the data to be processed and the device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs;

发送模块602,用于在从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎时,将待处理数据发送至目标数据处理引擎,其中,目标数据处理引擎至少包括:已调试的与设备标识对应的数据处理脚本,数据处理脚本用于处理待处理数据。The sending module 602 is used to send the data to be processed to the target data processing engine when a target data processing engine matching the device identifier is found from multiple initial data processing engines pre-stored in the local database, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identifier, and the data processing script is used to process the data to be processed.

在本公开的一些实施例中,用于医疗设备的数据处理装置60,还用于:In some embodiments of the present disclosure, the data processing device 60 for medical equipment is further used to:

在医疗设备在分布式处理引擎所属平台注册的情况下,获取每个医疗设备的候选设备标识;When the medical device is registered on the platform to which the distributed processing engine belongs, obtaining a candidate device identifier for each medical device;

获取与每个候选设备标识对应的候选处理脚本;Obtaining a candidate processing script corresponding to each candidate device identifier;

将候选处理脚本存储至云端数据库中。The candidate processing scripts are stored in a cloud database.

在本公开的一些实施例中,用于医疗设备的数据处理装置60,还用于:In some embodiments of the present disclosure, the data processing device 60 for medical equipment is further used to:

确定每个候选处理脚本在云端数据库中的存储地址; Determine the storage address of each candidate processing script in the cloud database;

将存储地址存储至分布式处理引擎所属平台的本地数据库中;Storing the storage address in a local database of the platform to which the distributed processing engine belongs;

为本地数据库中存储的存储地址分配索引项。Assign index entries to storage addresses stored in the local database.

在本公开的一些实施例中,用于医疗设备的数据处理装置60,还用于:In some embodiments of the present disclosure, the data processing device 60 for medical equipment is further used to:

将候选设备标识配置为本地数据库中存储的存储地址的索引项。The candidate device identification is configured as an index item of the storage address stored in the local database.

在本公开的一些实施例中,用于医疗设备的数据处理装置60,还用于:In some embodiments of the present disclosure, the data processing device 60 for medical equipment is further used to:

从本地数据库中多个索引项中确定与设备标识对应的目标索引项,其中,每个索引项用于索引一个存储地址;Determine a target index item corresponding to the device identifier from a plurality of index items in a local database, wherein each index item is used to index a storage address;

基于目标索引项从本地数据库中索引得到存储地址;Obtain storage address from local database based on target index item;

根据索引所得的存储地址,从云端数据库中存储的多个候选处理脚本中确定数据处理脚本。According to the storage address obtained by the index, a data processing script is determined from a plurality of candidate processing scripts stored in the cloud database.

在本公开的一些实施例中,用于医疗设备的数据处理装置60,还用于:In some embodiments of the present disclosure, the data processing device 60 for medical equipment is further used to:

从本地数据库中,确定多个候选设备标识;Determine multiple candidate device identifiers from a local database;

确定多个候选设备标识中与设备标识相同候选设备标识;Determine a candidate device identifier that is identical to the device identifier among multiple candidate device identifiers;

将相同候选设备标识作为目标索引项。The same candidate device identifier is used as the target index item.

在本公开的一些实施例中,用于医疗设备的数据处理装置60,还用于:In some embodiments of the present disclosure, the data processing device 60 for medical equipment is further used to:

如果未从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎,则基于数据处理脚本构建目标数据处理引擎。If a target data processing engine matching the device identifier is not found from a plurality of initial data processing engines pre-stored in the local database, the target data processing engine is constructed based on the data processing script.

与上述图1至图5实施例提供的用于医疗设备的数据处理方法相对应,本公开还提供一种用于医疗设备的数据处理装置,由于本公开实施例提供的用于医疗设备的数据处理装置与上述图1至图5实施例 提供的用于医疗设备的数据处理方法相对应,因此在用于医疗设备的数据处理方法的实施方式也适用于本公开实施例提供的用于医疗设备的数据处理装置,在本公开实施例中不再详细描述。Corresponding to the data processing method for medical equipment provided in the embodiments of FIGS. 1 to 5 above, the present disclosure further provides a data processing device for medical equipment. Since the data processing device for medical equipment provided in the embodiments of the present disclosure is consistent with the data processing method for medical equipment provided in the embodiments of FIGS. 1 to 5 above, The provided data processing method for medical equipment corresponds to the data processing method for medical equipment, so the implementation of the data processing method for medical equipment is also applicable to the data processing device for medical equipment provided in the embodiment of the present disclosure, and will not be described in detail in the embodiment of the present disclosure.

本实施例中,通过获取待处理数据和设备标识,其中,设备标识用于标识待处理数据所属医疗设备,并在从本地数据库中预先存储的多个初始数据处理引擎中查找到与设备标识相匹配的目标数据处理引擎时,将待处理数据发送至目标数据处理引擎,其中,目标数据处理引擎至少包括:已调试的与设备标识对应的数据处理脚本,数据处理脚本用于处理待处理数据,通过本公开,能够基于设备标识直接匹配到用于对待处理数据进行处理的目标数据处理引擎,且由于数据处理引擎中包含预先调试完成的与设备标识对应的数据处理脚本,从而无需重复引入数据处理脚本的开发,联调,测试,上线等一系列调试流程,进而在将待处理数据发送至目标数据处理引擎时,目标数据处理引擎能够直接基于编译数据处理脚本完成对待处理数据的处理,从而能够有效地简化数据处理的操作流程。In this embodiment, by obtaining the data to be processed and the device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs, and when a target data processing engine matching the device identification is found from multiple initial data processing engines pre-stored in a local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identification, and the data processing script is used to process the data to be processed. Through the present disclosure, it is possible to directly match the target data processing engine used to process the data to be processed based on the device identification, and because the data processing engine contains a pre-debugged data processing script corresponding to the device identification, there is no need to repeatedly introduce a series of debugging processes such as development, joint debugging, testing, and online launch of the data processing script, and then when the data to be processed is sent to the target data processing engine, the target data processing engine can directly complete the processing of the data to be processed based on the compiled data processing script, thereby effectively simplifying the data processing operation process.

图7是本公开一实施例提出的用于医疗设备的数据处理装置的结构示意图。FIG. 7 is a schematic diagram of the structure of a data processing device for medical equipment proposed in an embodiment of the present disclosure.

如图7所示,该用于医疗设备的数据处理装置70,包括:As shown in FIG. 7 , the data processing device 70 for medical equipment includes:

接收模块701,用于接收分布式处理引擎发送的医疗设备的待处理数据,其中,待处理数据所属医疗设备具有设备标识;The receiving module 701 is used to receive the to-be-processed data of the medical device sent by the distributed processing engine, wherein the medical device to which the to-be-processed data belongs has a device identification;

处理模块702,用于根据数据处理脚本处理待处理数据,其中,数据处理脚本与设备标识相对应。The processing module 702 is used to process the data to be processed according to the data processing script, wherein the data processing script corresponds to the device identifier.

与上述图1至图5实施例提供的用于医疗设备的数据处理方法相对应,本公开还提供一种用于医疗设备的数据处理装置,由于本公开实施例提供的用于医疗设备的数据处理装置与上述图1至图5实施例提供的用于医疗设备的数据处理方法相对应,因此在用于医疗设备的 数据处理方法的实施方式也适用于本公开实施例提供的用于医疗设备的数据处理装置,在本公开实施例中不再详细描述。Corresponding to the data processing method for medical equipment provided in the embodiments of FIGS. 1 to 5 above, the present disclosure further provides a data processing device for medical equipment. Since the data processing device for medical equipment provided in the embodiments of the present disclosure corresponds to the data processing method for medical equipment provided in the embodiments of FIGS. 1 to 5 above, The implementation of the data processing method is also applicable to the data processing device for medical equipment provided in the embodiment of the present disclosure, and will not be described in detail in the embodiment of the present disclosure.

本公开实施例中,通过接收分布式处理引擎发送的医疗设备的待处理数据,其中,待处理数据所属医疗设备具有设备标识,并根据数据处理脚本处理待处理数据,其中,数据处理脚本与设备标识相对应,由此,可以使得数据处理脚本可以独立在目标数据处理引擎中编译,且能够支持多引擎之间独立运行,有效地避免同时处理多设备数据之间相互影响,有效地保障数据处理效果。In the disclosed embodiment, the data to be processed of the medical device sent by the distributed processing engine is received, wherein the medical device to which the data to be processed belongs has a device identification, and the data to be processed is processed according to a data processing script, wherein the data processing script corresponds to the device identification. Thus, the data processing script can be independently compiled in the target data processing engine, and can support independent operation between multiple engines, effectively avoiding mutual influence between the simultaneous processing of data from multiple devices, and effectively ensuring the data processing effect.

为了实现上述实施例,本公开还提出一种电子设备,包括:存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,处理器执行程序时,实现如本公开前述实施例提出的用于医疗设备的数据处理方法。In order to implement the above embodiments, the present disclosure also proposes an electronic device, including: a memory, a processor, and a computer program stored in the memory and executable on the processor. When the processor executes the program, it implements the data processing method for medical equipment proposed in the above embodiments of the present disclosure.

为了实现上述实施例,本公开还提出一种非临时性计算机可读存储介质,其上存储有计算机程序,该程序被处理器执行时实现如本公开前述实施例提出的用于医疗设备的数据处理方法。In order to implement the above embodiments, the present disclosure also proposes a non-temporary computer-readable storage medium on which a computer program is stored. When the program is executed by a processor, it implements the data processing method for medical equipment proposed in the above embodiments of the present disclosure.

为了实现上述实施例,本公开还提出一种计算机程序产品,当计算机程序产品中的指令处理器执行时,执行如本公开前述实施例提出的用于医疗设备的数据处理方法。In order to implement the above embodiments, the present disclosure further proposes a computer program product. When an instruction processor in the computer program product executes, the data processing method for a medical device proposed in the above embodiments of the present disclosure is executed.

图8示出了适于用来实现本公开实施方式的示例性电子设备的框图。图8显示的电子设备仅仅是一个示例,不应对本公开实施例的功能和使用范围带来任何限制。Fig. 8 shows a block diagram of an exemplary electronic device suitable for implementing the embodiments of the present disclosure. The electronic device shown in Fig. 8 is only an example and should not bring any limitation to the functions and scope of use of the embodiments of the present disclosure.

如图8所示,电子设备以通用计算设备的形式表现。电子设备的组件可以包括但不限于:一个或者多个处理器或者处理单元16,系统存储器28,连接不同系统组件(包括系统存储器28和处理单元16) 的总线18。As shown in FIG8 , the electronic device is presented in the form of a general-purpose computing device. The components of the electronic device may include, but are not limited to: one or more processors or processing units 16, a system memory 28, and a computer that connects different system components (including the system memory 28 and the processing unit 16). Bus 18.

总线18表示几类总线结构中的一种或多种,包括存储器总线或者存储器控制器,外围总线,图形加速端口,处理器或者使用多种总线结构中的任意总线结构的局域总线。举例来说,这些体系结构包括但不限于工业标准体系结构(Industry Standard Architecture;以下简称:ISA)总线,微通道体系结构(Micro Channel Architecture;以下简称:MAC)总线,增强型ISA总线、视频电子标准协会(Video Electronics Standards Association;以下简称:VESA)局域总线以及外围组件互连(Peripheral Component Interconnection;以下简称:PCI)总线。Bus 18 represents one or more of several types of bus structures, including a memory bus or memory controller, a peripheral bus, a graphics acceleration port, a processor or a local bus using any of a variety of bus structures. For example, these architectures include but are not limited to Industry Standard Architecture (hereinafter referred to as: ISA) bus, Micro Channel Architecture (hereinafter referred to as: MAC) bus, Enhanced ISA bus, Video Electronics Standards Association (hereinafter referred to as: VESA) local bus and Peripheral Component Interconnection (hereinafter referred to as: PCI) bus.

电子设备典型地包括多种计算机系统可读介质。这些介质可以是任何能够被电子设备访问的可用介质,包括易失性和非易失性介质,可移动的和不可移动的介质。Electronic devices typically include a variety of computer system readable media. These media can be any available media that can be accessed by the electronic device, including volatile and non-volatile media, removable and non-removable media.

存储器28可以包括易失性存储器形式的计算机系统可读介质,例如随机存取存储器(Random Access Memory;以下简称:RAM)30和/或高速缓存存储器32。电子设备可以进一步包括其他可移动/不可移动的、易失性/非易失性计算机系统存储介质。仅作为举例,存储系统34可以用于读写不可移动的、非易失性磁介质(图8未显示,通常称为“硬盘驱动器”)。The memory 28 may include computer system readable media in the form of volatile memory, such as random access memory (RAM) 30 and/or cache memory 32. The electronic device may further include other removable/non-removable, volatile/non-volatile computer system storage media. By way of example only, the storage system 34 may be used to read and write non-removable, non-volatile magnetic media (not shown in FIG. 8 , commonly referred to as a “hard drive”).

尽管图8中未示出,可以提供用于对可移动非易失性磁盘(例如“软盘”)读写的磁盘驱动器,以及对可移动非易失性光盘(例如:光盘只读存储器(Compact Disc Read Only Memory;以下简称:CD-ROM)、数字多功能只读光盘(Digital Video Disc Read Only Memory;以下简称:DVD-ROM)或者其他光介质)读写的光盘驱动器。在这些情况下,每个驱动器可以通过一个或者多个数据介质接口与总线18相连。存储器28可以包括至少一个程序产品,该程序产品具有一组(例如至少一个)程序模块,这些程序模块被配置以执行本公开各实施例的功能。 Although not shown in FIG. 8 , a disk drive for reading and writing a removable nonvolatile disk (e.g., a “floppy disk”) and an optical disk drive for reading and writing a removable nonvolatile optical disk (e.g., a compact disc read only memory (CD-ROM), a digital versatile disc read only memory (DVD-ROM), or other optical media) may be provided. In these cases, each drive may be connected to the bus 18 via one or more data medium interfaces. The memory 28 may include at least one program product having a set (e.g., at least one) of program modules configured to perform the functions of the various embodiments of the present disclosure.

具有一组(至少一个)程序模块42的程序/实用工具40,可以存储在例如存储器28中,这样的程序模块42包括但不限于操作系统、一个或者多个应用程序、其他程序模块以及程序数据,这些示例中的每一个或某种组合中可能包括网络环境的实现。程序模块42通常执行本公开所描述的实施例中的功能和/或方法。A program/utility 40 having a set (at least one) of program modules 42 may be stored, for example, in the memory 28, such program modules 42 including but not limited to an operating system, one or more application programs, other program modules, and program data, each of which or some combination may include an implementation of a network environment. The program modules 42 generally perform the functions and/or methods of the embodiments described in the present disclosure.

电子设备也可以与一个或多个外部设备14(例如键盘、指向设备、显示器24等)通信,还可与一个或者多个使得用户能与该电子设备交互的设备通信,和/或与使得该电子设备能与一个或多个其他计算设备进行通信的任何设备(例如网卡,调制解调器等等)通信。这种通信可以通过输入/输出(I/O)接口22进行。并且,电子设备还可以通过网络适配器20与一个或者多个网络(例如局域网(Local Area Network;以下简称:LAN),广域网(Wide Area Network;以下简称:WAN)和/或公共网络,例如因特网)通信。如图所示,网络适配器20通过总线18与电子设备的其他模块通信。应当明白,尽管图中未示出,可以结合电子设备使用其他硬件和/或软件模块,包括但不限于:微代码、设备驱动器、冗余处理单元、外部磁盘驱动阵列、RAID系统、磁带驱动器以及数据备份存储系统等。The electronic device may also communicate with one or more external devices 14 (e.g., keyboard, pointing device, display 24, etc.), may also communicate with one or more devices that enable a user to interact with the electronic device, and/or communicate with any device that enables the electronic device to communicate with one or more other computing devices (e.g., network card, modem, etc.). Such communication may be performed through an input/output (I/O) interface 22. Furthermore, the electronic device may also communicate with one or more networks (e.g., a local area network (LAN), a wide area network (WAN), and/or a public network, such as the Internet) through a network adapter 20. As shown, the network adapter 20 communicates with other modules of the electronic device through a bus 18. It should be understood that, although not shown in the figure, other hardware and/or software modules may be used in conjunction with the electronic device, including but not limited to: microcode, device drivers, redundant processing units, external disk drive arrays, RAID systems, tape drives, and data backup storage systems.

处理单元16通过运行存储在系统存储器28中的程序,从而执行各种功能应用以及数据处理,例如实现前述实施例中提及的用于医疗设备的数据处理方法。The processing unit 16 executes various functional applications and data processing by running the programs stored in the system memory 28, such as implementing the data processing method for medical equipment mentioned in the above embodiments.

本领域技术人员在考虑说明书及实践这里公开的发明后,将容易想到本公开的其他实施方案。本公开旨在涵盖本公开的任何变型、用途或者适应性变化,这些变型、用途或者适应性变化遵循本公开的一般性原理并包括本公开未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的,本公开的真正范围和精神由下面的权利要求指出。 Those skilled in the art will readily appreciate other embodiments of the present disclosure after considering the specification and practicing the invention disclosed herein. The present disclosure is intended to cover any variations, uses, or adaptations of the present disclosure that follow the general principles of the present disclosure and include common knowledge or customary techniques in the art that are not disclosed in the present disclosure. The description and examples are to be considered exemplary only, and the true scope and spirit of the present disclosure are indicated by the following claims.

应当理解的是,本公开并不局限于上面已经描述并在附图中示出的精确结构,并且可以在不脱离其范围进行各种修改和改变。本公开的范围仅由所附的权利要求来限制。It should be understood that the present disclosure is not limited to the exact structures that have been described above and shown in the drawings, and that various modifications and changes may be made without departing from the scope thereof. The scope of the present disclosure is limited only by the appended claims.

需要说明的是,在本公开的描述中,术语“第一”、“第二”等仅用于描述目的,而不能理解为指示或暗示相对重要性。此外,在本公开的描述中,除非另有说明,“多个”的含义是两个或两个以上。It should be noted that, in the description of the present disclosure, the terms "first", "second", etc. are only used for descriptive purposes and cannot be understood as indicating or implying relative importance. In addition, in the description of the present disclosure, unless otherwise specified, the meaning of "plurality" is two or more.

流程图中或在此以其他方式描述的任何过程或方法描述可以被理解为,表示包括一个或更多个用于实现特定逻辑功能或过程的步骤的可执行指令的代码的模块、片段或部分,并且本公开的优选实施方式的范围包括另外的实现,其中可以不按所示出或讨论的顺序,包括根据所涉及的功能按基本同时的方式或按相反的顺序,来执行功能,这应被本公开的实施例所属技术领域的技术人员所理解。Any process or method description in a flowchart or otherwise described herein may be understood to represent a module, segment or portion of code that includes one or more executable instructions for implementing the steps of a specific logical function or process, and the scope of the preferred embodiments of the present disclosure includes alternative implementations in which functions may not be performed in the order shown or discussed, including performing functions in a substantially simultaneous manner or in the reverse order depending on the functions involved, which should be understood by those skilled in the art to which the embodiments of the present disclosure belong.

应当理解,本公开的各部分可以用硬件、软件、固件或它们的组合来实现。在上述实施方式中,多个步骤或方法可以用存储在存储器中且由合适的指令执行系统执行的软件或固件来实现。例如,如果用硬件来实现,和在另一实施方式中一样,可用本领域公知的下列技术中的任一项或他们的组合来实现:具有用于对数据信号实现逻辑功能的逻辑门电路的离散逻辑电路,具有合适的组合逻辑门电路的专用集成电路,可编程门阵列(PGA),现场可编程门阵列(FPGA)等。It should be understood that the various parts of the present disclosure can be implemented in hardware, software, firmware or a combination thereof. In the above-mentioned embodiments, multiple steps or methods can be implemented in software or firmware stored in a memory and executed by a suitable instruction execution system. For example, if implemented in hardware, as in another embodiment, it can be implemented by any one of the following technologies known in the art or their combination: a discrete logic circuit having a logic gate circuit for implementing a logic function for a data signal, a dedicated integrated circuit having a suitable combination of logic gate circuits, a programmable gate array (PGA), a field programmable gate array (FPGA), etc.

本技术领域的普通技术人员可以理解实现上述实施例方法携带的全部或部分步骤是可以通过程序来指令相关的硬件完成,所述的程序可以存储于一种计算机可读存储介质中,该程序在执行时,包括方法实施例的步骤之一或其组合。A person skilled in the art may understand that all or part of the steps in the method for implementing the above-mentioned embodiment may be completed by instructing related hardware through a program, and the program may be stored in a computer-readable storage medium, which, when executed, includes one or a combination of the steps of the method embodiment.

此外,在本公开各个实施例中的各功能单元可以集成在一个处理 模块中,也可以是各个单元单独物理存在,也可以两个或两个以上单元集成在一个模块中。上述集成的模块既可以采用硬件的形式实现,也可以采用软件功能模块的形式实现。所述集成的模块如果以软件功能模块的形式实现并作为独立的产品销售或使用时,也可以存储在一个计算机可读取存储介质中。In addition, each functional unit in each embodiment of the present disclosure can be integrated into a processing unit. In the module, each unit may exist physically separately, or two or more units may be integrated into one module. The above-mentioned integrated module may be implemented in the form of hardware or in the form of a software functional module. If the integrated module is implemented in the form of a software functional module and sold or used as an independent product, it may also be stored in a computer-readable storage medium.

上述提到的存储介质可以是只读存储器,磁盘或光盘等。The storage medium mentioned above can be a read-only memory, a magnetic disk or an optical disk, etc.

在本说明书的描述中,参考术语“一个实施例”、“一些实施例”、“示例”、“具体示例”、或“一些示例”等的描述意指结合该实施例或示例描述的具体特征、结构、材料或者特点包含于本公开的至少一个实施例或示例中。在本说明书中,对上述术语的示意性表述不一定指的是相同的实施例或示例。而且,描述的具体特征、结构、材料或者特点可以在任何的一个或多个实施例或示例中以合适的方式结合。In the description of this specification, the description with reference to the terms "one embodiment", "some embodiments", "example", "specific example", or "some examples" means that the specific features, structures, materials or characteristics described in conjunction with the embodiment or example are included in at least one embodiment or example of the present disclosure. In this specification, the schematic representation of the above terms does not necessarily refer to the same embodiment or example. Moreover, the specific features, structures, materials or characteristics described may be combined in any one or more embodiments or examples in a suitable manner.

尽管上面已经示出和描述了本公开的实施例,可以理解的是,上述实施例是示例性的,不能理解为对本公开的限制,本领域的普通技术人员在本公开的范围内可以对上述实施例进行变化、修改、替换和变型。 Although the embodiments of the present disclosure have been shown and described above, it is to be understood that the above embodiments are illustrative and are not to be construed as limitations of the present disclosure. A person skilled in the art may change, modify, replace and vary the above embodiments within the scope of the present disclosure.

Claims (12)

一种用于医疗设备的数据处理方法,其被分布式处理引擎执行,所述方法包括:A data processing method for a medical device, which is executed by a distributed processing engine, the method comprising: 获取待处理数据和设备标识,其中,所述设备标识用于标识所述待处理数据所属医疗设备;Acquire the data to be processed and the device identification, wherein the device identification is used to identify the medical device to which the data to be processed belongs; 如果从本地数据库中预先存储的多个初始数据处理引擎中查找到与所述设备标识相匹配的目标数据处理引擎,则将所述待处理数据发送至所述目标数据处理引擎,其中,所述目标数据处理引擎至少包括:已调试的与所述设备标识对应的数据处理脚本,所述数据处理脚本用于处理所述待处理数据。If a target data processing engine matching the device identifier is found from a plurality of initial data processing engines pre-stored in a local database, the data to be processed is sent to the target data processing engine, wherein the target data processing engine includes at least: a debugged data processing script corresponding to the device identifier, and the data processing script is used to process the data to be processed. 如权利要求1所述的方法,其中,所述方法还包括:The method according to claim 1, wherein the method further comprises: 在所述医疗设备在所述分布式处理引擎所属平台注册的情况下,获取每个所述医疗设备的候选设备标识;When the medical device is registered on the platform to which the distributed processing engine belongs, obtaining a candidate device identification of each medical device; 获取与每个所述候选设备标识对应的候选处理脚本;Obtaining a candidate processing script corresponding to each of the candidate device identifiers; 将所述候选处理脚本存储至云端数据库中。The candidate processing scripts are stored in a cloud database. 如权利要求2所述的方法,其中,在所述将所述候选处理脚本存储至云端数据库中之后,所述方法还包括:The method according to claim 2, wherein after storing the candidate processing script in a cloud database, the method further comprises: 确定每个所述候选处理脚本在所述云端数据库中的存储地址;Determine a storage address of each of the candidate processing scripts in the cloud database; 将所述存储地址存储至所述分布式处理引擎所属平台的本地数据库中;Storing the storage address in a local database of the platform to which the distributed processing engine belongs; 为所述本地数据库中存储的所述存储地址分配索引项。An index item is assigned to the storage address stored in the local database. 如权利要求3所述的方法,其中,所述为所述本地数据库中存储的所述存储地址分配索引项,包括:The method of claim 3, wherein the assigning of index items to the storage addresses stored in the local database comprises: 将所述候选设备标识配置为所述本地数据库中存储的所述存储地址的索引项。 The candidate device identification is configured as an index item of the storage address stored in the local database. 如权利要求3所述的方法,其中,所述方法还包括:The method according to claim 3, wherein the method further comprises: 从所述本地数据库中多个所述索引项中确定与所述设备标识对应的目标索引项,其中,每个所述索引项用于索引一个存储地址;Determine a target index item corresponding to the device identifier from a plurality of the index items in the local database, wherein each of the index items is used to index a storage address; 基于所述目标索引项从所述本地数据库中索引得到所述存储地址;Obtaining the storage address from the local database based on the target index item; 根据所述索引所得的所述存储地址,从所述云端数据库中存储的多个所述候选处理脚本中确定所述数据处理脚本。According to the storage address obtained by the index, the data processing script is determined from the plurality of candidate processing scripts stored in the cloud database. 如权利要求5所述的方法,其中,所述从所述本地数据库的多个所述索引项中确定与所述设备标识对应的目标索引项,包括:The method of claim 5, wherein determining the target index item corresponding to the device identifier from the plurality of index items in the local database comprises: 从所述本地数据库中,确定多个候选设备标识;Determining a plurality of candidate device identifiers from the local database; 确定所述多个候选设备标识中与所述设备标识相同候选设备标识;Determine a candidate device identifier that is identical to the device identifier among the multiple candidate device identifiers; 将所述相同候选设备标识作为所述目标索引项。The same candidate device identifier is used as the target index item. 如权利要求1所述的方法,其中,所述方法还包括:The method according to claim 1, wherein the method further comprises: 如果未从所述本地数据库中预先存储的多个所述初始数据处理引擎中查找到与所述设备标识相匹配的所述目标数据处理引擎,则基于所述数据处理脚本构建所述目标数据处理引擎。If the target data processing engine matching the device identifier is not found from the plurality of initial data processing engines pre-stored in the local database, the target data processing engine is constructed based on the data processing script. 一种用于医疗设备的数据处理方法,其被目标数据处理引擎执行,所述目标数据处理引擎至少包括数据处理脚本,所述方法包括:A data processing method for a medical device, which is executed by a target data processing engine, the target data processing engine at least comprising a data processing script, the method comprising: 接收分布式处理引擎发送的医疗设备的待处理数据,其中,所述待处理数据所属医疗设备具有设备标识;Receiving data to be processed from a medical device sent by a distributed processing engine, wherein the medical device to which the data to be processed belongs has a device identifier; 根据所述数据处理脚本处理所述待处理数据,其中,所述数据处理脚本与所述设备标识相对应。The data to be processed is processed according to the data processing script, wherein the data processing script corresponds to the device identifier. 一种用于医疗设备的数据处理装置,其被分布式处理引擎执行,所述装置包括:A data processing device for medical equipment, which is executed by a distributed processing engine, comprising: 获取模块,用于获取待处理数据和设备标识,其中,所述设备标识用于标识所述待处理数据所属医疗设备;An acquisition module, used for acquiring the data to be processed and a device identification, wherein the device identification is used for identifying the medical device to which the data to be processed belongs; 发送模块,用于在从本地数据库中预先存储的多个初始数据处理 引擎中查找到与所述设备标识相匹配的目标数据处理引擎时,将所述待处理数据发送至所述目标数据处理引擎,其中,所述目标数据处理引擎至少包括:已调试的与所述设备标识对应的数据处理脚本,所述数据处理脚本用于处理所述待处理数据。The sending module is used to process multiple initial data pre-stored in the local database When a target data processing engine matching the device identifier is found in the engine, the data to be processed is sent to the target data processing engine, wherein the target data processing engine at least includes: a debugged data processing script corresponding to the device identifier, and the data processing script is used to process the data to be processed. 一种用于医疗设备的数据处理装置,其被目标数据处理引擎执行,所述目标数据处理引擎至少包括数据处理脚本,所述装置包括:A data processing device for medical equipment, which is executed by a target data processing engine, the target data processing engine at least comprising a data processing script, the device comprising: 接收模块,用于接收分布式处理引擎发送的医疗设备的待处理数据,其中,所述待处理数据所属医疗设备具有设备标识;A receiving module, used for receiving the to-be-processed data of the medical device sent by the distributed processing engine, wherein the medical device to which the to-be-processed data belongs has a device identification; 处理模块,用于根据所述数据处理脚本处理所述待处理数据,其中,所述数据处理脚本与所述设备标识相对应。A processing module is used to process the data to be processed according to the data processing script, wherein the data processing script corresponds to the device identifier. 一种电子设备,包括:An electronic device, comprising: 至少一个处理器;以及at least one processor; and 与所述至少一个处理器通信连接的存储器,a memory communicatively coupled to the at least one processor, 其中,in, 所述存储器存储有可被所述至少一个处理器执行的指令,所述指令被所述至少一个处理器执行,以使所述至少一个处理器能够执行权利要求1-7中任一项所述的方法,或者执行权利要求8中所述的方法。The memory stores instructions that can be executed by the at least one processor, and the instructions are executed by the at least one processor to enable the at least one processor to execute the method described in any one of claims 1 to 7, or execute the method described in claim 8. 一种存储有计算机指令的非瞬时计算机可读存储介质,其中,所述计算机指令用于使所述计算机执行权利要求1-7中任一项所述的方法,或者执行权利要求8中所述的方法。 A non-transitory computer-readable storage medium storing computer instructions, wherein the computer instructions are used to cause the computer to execute the method of any one of claims 1 to 7, or to execute the method of claim 8.
PCT/CN2024/076645 2023-03-03 2024-02-07 Data processing method and apparatus for medical device, electronic device, and medium Pending WO2024183529A1 (en)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN202310207537.4 2023-03-03
CN202310207537.4A CN118588266A (en) 2023-03-03 2023-03-03 Data processing method, device, electronic device and medium for medical equipment

Publications (1)

Publication Number Publication Date
WO2024183529A1 true WO2024183529A1 (en) 2024-09-12

Family

ID=92523336

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2024/076645 Pending WO2024183529A1 (en) 2023-03-03 2024-02-07 Data processing method and apparatus for medical device, electronic device, and medium

Country Status (2)

Country Link
CN (1) CN118588266A (en)
WO (1) WO2024183529A1 (en)

Citations (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101384015A (en) * 2008-09-28 2009-03-11 华为技术有限公司 Distributed telecommunication equipment and method for processing services by distributed telecommunication equipment
US20120323601A1 (en) * 2011-06-14 2012-12-20 Microsoft Corporation Distributed sharing of electronic medical records
CN107025274A (en) * 2017-03-21 2017-08-08 华中科技大学 Equipment health status intelligent perception system and method based on Hadoop
US20210125725A1 (en) * 2019-10-29 2021-04-29 International Business Machines Corporation Automated Medical Device Regulation Risk Assessments
CN114694784A (en) * 2022-03-25 2022-07-01 智业软件股份有限公司 Method, system, device and storage medium for processing medical data of patient
US20220215948A1 (en) * 2021-01-07 2022-07-07 Abiomed, Inc. Network-based medical apparatus control and data management systems
CN115328492A (en) * 2022-08-23 2022-11-11 京东科技控股股份有限公司 Data processing method and device, electronic equipment and storage medium

Patent Citations (7)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101384015A (en) * 2008-09-28 2009-03-11 华为技术有限公司 Distributed telecommunication equipment and method for processing services by distributed telecommunication equipment
US20120323601A1 (en) * 2011-06-14 2012-12-20 Microsoft Corporation Distributed sharing of electronic medical records
CN107025274A (en) * 2017-03-21 2017-08-08 华中科技大学 Equipment health status intelligent perception system and method based on Hadoop
US20210125725A1 (en) * 2019-10-29 2021-04-29 International Business Machines Corporation Automated Medical Device Regulation Risk Assessments
US20220215948A1 (en) * 2021-01-07 2022-07-07 Abiomed, Inc. Network-based medical apparatus control and data management systems
CN114694784A (en) * 2022-03-25 2022-07-01 智业软件股份有限公司 Method, system, device and storage medium for processing medical data of patient
CN115328492A (en) * 2022-08-23 2022-11-11 京东科技控股股份有限公司 Data processing method and device, electronic equipment and storage medium

Also Published As

Publication number Publication date
CN118588266A (en) 2024-09-03

Similar Documents

Publication Publication Date Title
CN113887161B (en) A verification method, device, equipment and medium for a network-on-chip design example
CN111563014A (en) Interface service performance test method, device, equipment and storage medium
JP2017117442A (en) Method and device for data flow analysis in processor trace log using compiler-type information
CN112181485A (en) Script execution method and device, electronic equipment and storage medium
CN111400189A (en) Code coverage monitoring method, device, electronic device and storage medium
CN110674034A (en) Health examination method and device, electronic equipment and storage medium
WO2018195795A1 (en) Test method, test server, and system
US20210160259A1 (en) System for automated signature generation and refinement
CN111338958A (en) Parameter generation method and device of test case and terminal equipment
CN108337301A (en) Network request processing method, device, server and the storage medium of application program
CN112328458A (en) Data processing method and device based on flink data engine
CN114388082A (en) Method and device for verifying medical scientific research data
WO2024183529A1 (en) Data processing method and apparatus for medical device, electronic device, and medium
CN115017054A (en) Data synchronization test method, device, electronic device and storage medium
CN114721952A (en) Synchronous deployment method, device, equipment and storage medium for multiple sets of test environments
CN114003784A (en) Request recording method, device, equipment and storage medium
CN114253593A (en) Application program information feedback method, device, terminal device and storage medium
CN113157554A (en) Software automation question making test method and related equipment
CN118796703A (en) Command test method, device, electronic device, storage medium and program product
CN103034719B (en) CPU type identifier method, equipment and hardware detection system
CN118689766A (en) Cache consistency testing method, device, electronic device and storage medium
CN115101152A (en) Sample priority switching method, device, equipment and medium
CN115794621A (en) Code coverage test method, device, equipment and storage medium
JP2013506898A (en) Method and apparatus for optimizing the execution of software applications in a multiprocessor architecture comprising a plurality of input / output controllers and auxiliary arithmetic units
CN118280538B (en) Medical text information processing method and device

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 24766251

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE