CN113761246A - Data acquisition method and device, electronic equipment and storage medium - Google Patents
- ️Tue Dec 07 2021
CN113761246A - Data acquisition method and device, electronic equipment and storage medium - Google Patents
Data acquisition method and device, electronic equipment and storage medium Download PDFInfo
-
Publication number
- CN113761246A CN113761246A CN202111040951.8A CN202111040951A CN113761246A CN 113761246 A CN113761246 A CN 113761246A CN 202111040951 A CN202111040951 A CN 202111040951A CN 113761246 A CN113761246 A CN 113761246A Authority
- CN
- China Prior art keywords
- data
- node
- user node
- data acquisition
- user Prior art date
- 2021-09-06 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.)
- Granted
Links
- 238000000034 method Methods 0.000 title claims abstract description 53
- 238000004590 computer program Methods 0.000 claims description 18
- 238000004891 communication Methods 0.000 claims description 16
- 238000003384 imaging method Methods 0.000 claims description 7
- 238000007726 management method Methods 0.000 abstract description 6
- 238000013523 data management Methods 0.000 abstract description 4
- 238000010586 diagram Methods 0.000 description 12
- 230000005291 magnetic effect Effects 0.000 description 9
- 230000008569 process Effects 0.000 description 8
- 238000012545 processing Methods 0.000 description 8
- 230000001360 synchronised effect Effects 0.000 description 8
- 230000005540 biological transmission Effects 0.000 description 6
- 230000006870 function Effects 0.000 description 5
- 238000005516 engineering process Methods 0.000 description 4
- 238000004519 manufacturing process Methods 0.000 description 3
- 230000003287 optical effect Effects 0.000 description 3
- 230000003068 static effect Effects 0.000 description 3
- 230000008859 change Effects 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000002085 persistent effect Effects 0.000 description 2
- 238000005481 NMR spectroscopy Methods 0.000 description 1
- 238000013475 authorization Methods 0.000 description 1
- 229940079593 drug Drugs 0.000 description 1
- 239000003814 drug Substances 0.000 description 1
- 230000005294 ferromagnetic effect Effects 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 238000012384 transportation and delivery Methods 0.000 description 1
- 238000002604 ultrasonography Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/50—Information retrieval; Database structures therefor; File system structures therefor of still image data
- G06F16/53—Querying
- G06F16/535—Filtering based on additional data, e.g. user or group profiles
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/50—Information retrieval; Database structures therefor; File system structures therefor of still image data
- G06F16/58—Retrieval characterised by using metadata, e.g. metadata not derived from the content or metadata generated manually
- G06F16/5866—Retrieval characterised by using metadata, e.g. metadata not derived from the content or metadata generated manually using information manually generated, e.g. tags, keywords, comments, manually generated location and time information
-
- G—PHYSICS
- G16—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR SPECIFIC APPLICATION FIELDS
- G16H—HEALTHCARE INFORMATICS, i.e. INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR THE HANDLING OR PROCESSING OF MEDICAL OR HEALTHCARE DATA
- G16H30/00—ICT specially adapted for the handling or processing of medical images
- G16H30/20—ICT specially adapted for the handling or processing of medical images for handling medical images, e.g. DICOM, HL7 or PACS
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- General Physics & Mathematics (AREA)
- Health & Medical Sciences (AREA)
- General Engineering & Computer Science (AREA)
- Physics & Mathematics (AREA)
- Databases & Information Systems (AREA)
- Epidemiology (AREA)
- Library & Information Science (AREA)
- Public Health (AREA)
- Primary Health Care (AREA)
- Medical Informatics (AREA)
- General Health & Medical Sciences (AREA)
- Radiology & Medical Imaging (AREA)
- Nuclear Medicine, Radiotherapy & Molecular Imaging (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
本发明公开了一种数据获取方法、装置、电子设备和存储介质。其中，方法包括：确定数据查询信息；其中，所述数据查询信息包含数据所在的用户节点信息和至少一个维度的数据查询条件；根据所述用户节点信息确定所述用户节点信息所对应的边缘节点；向所述边缘节点发送携带有所述数据查询条件的数据获取请求，并接收所述边缘节点根据所述数据查询条件返回的数据。采用本发明提供的方案能实现对用户节点存储的数据进行统一化管理，解决了以往数据管理混乱的问题，并且利用中心节点进行统一的管理和调度，还能实现从用户节点获取数据时，通过中心节点的指令多维度地从用户节点查询和获取数据。
The invention discloses a data acquisition method, device, electronic device and storage medium. The method includes: determining data query information; wherein the data query information includes user node information where the data is located and data query conditions of at least one dimension; and determining an edge node corresponding to the user node information according to the user node information ; Send a data acquisition request carrying the data query condition to the edge node, and receive the data returned by the edge node according to the data query condition. The solution provided by the invention can realize the unified management of the data stored in the user node, solve the problem of confusion in data management in the past, and use the central node to carry out unified management and scheduling, and also realize that when acquiring data from the user node, the The instructions of the central node query and obtain data from the user nodes in multiple dimensions.
Description
技术领域technical field
本发明涉及计算机技术领域，尤其涉及一种数据获取方法、装置、电子设备和存储介质。The present invention relates to the field of computer technology, and in particular, to a data acquisition method, apparatus, electronic device and storage medium.
背景技术Background technique
目前，医院的电子体系中的影像归档和通信系统(Picture Archiving andCommunication Systems，PACS)会以医学数字成像和通信(Digital Imaging andCommunications in Medicine，DICOM)格式存储影像数据，并通过DICOM服务进行传输。At present, the Image Archiving and Communication Systems (PACS) in the electronic system of the hospital will store the image data in the Digital Imaging and Communications in Medicine (DICOM) format and transmit it through the DICOM service.
相关技术中利用DICOM服务传输数据，主要是在DICOM服务client端(ServiceClass User、DICOM SCU)(这里可理解为PACS工作站)与DICOM服务server端(ServiceClass Provider，DICOM SCP)(这里可理解为PACS服务器)之间进行传输。即PACS工作站通过DICOM协议和PACS服务器建立连接，对PACS系统中的DICOM医学影像列表进行查询并获取DICOM医学影像信息。In the related art, the DICOM service is used to transmit data, mainly in the DICOM service client side (ServiceClass User, DICOM SCU) (here can be understood as PACS workstation) and the DICOM service server side (ServiceClass Provider, DICOM SCP) (here can be understood as PACS server) ) are transferred between. That is, the PACS workstation establishes a connection with the PACS server through the DICOM protocol, queries the DICOM medical image list in the PACS system, and obtains the DICOM medical image information.
目前，DICOM服务采用的架构是多个PACS工作站对应一个PACS服务器，PACS服务器之间相互独立。但这种架构会导致PACS服务器存在管理混乱，无法对PACS工作站进行统一的管理。另外，在上述架构中，单个PACS服务器与单个PACS工作站之间仅能通过预设好的确定维度的查询条件查询和获取数据，无法通过灵活的多维度的查询条件进行查询和获取，因此，上述架构中DICOM医学影像信息的查询条件维度较为单一，无法或很难自适应多种维度的查询和获取DICOM医学影像数据。At present, the architecture adopted by the DICOM service is that multiple PACS workstations correspond to one PACS server, and the PACS servers are independent of each other. However, this kind of architecture will lead to confusion in the management of the PACS server, and it is impossible to manage the PACS workstations in a unified manner. In addition, in the above architecture, a single PACS server and a single PACS workstation can only query and obtain data through preset query conditions that determine dimensions, and cannot query and obtain data through flexible multi-dimensional query conditions. Therefore, the above The query condition dimension of DICOM medical image information in the architecture is relatively single, and it is impossible or difficult to adapt to multiple dimensions of query and obtain DICOM medical image data.
发明内容SUMMARY OF THE INVENTION
为解决相关技术问题，本发明实施例提供一种数据获取方法、装置、电子设备和存储介质。To solve related technical problems, embodiments of the present invention provide a data acquisition method, apparatus, electronic device, and storage medium.
本发明实施例的技术方案是这样实现的：The technical solution of the embodiment of the present invention is realized as follows:
本发明实施例提供了一种数据获取方法，应用于中心节点，中心节点与至少一个边缘节点连接，边缘节点与至少一个用户节点连接，用户节点设置有PACS系统，方法包括：An embodiment of the present invention provides a data acquisition method, which is applied to a central node. The central node is connected to at least one edge node, the edge node is connected to at least one user node, and the user node is provided with a PACS system. The method includes:
确定数据查询信息；其中，数据查询信息包含数据所在的用户节点信息和至少一个维度的数据查询条件；Determine data query information; wherein, the data query information includes user node information where the data is located and data query conditions of at least one dimension;
根据用户节点信息确定用户节点信息所对应的边缘节点；Determine the edge node corresponding to the user node information according to the user node information;
向边缘节点发送携带有数据查询条件的数据获取请求，并接收边缘节点根据数据查询条件返回的数据。Send a data acquisition request carrying data query conditions to the edge node, and receive data returned by the edge node according to the data query conditions.
上述方案中，向边缘节点发送携带有数据查询条件的数据获取请求，包括：In the above solution, a data acquisition request carrying data query conditions is sent to the edge node, including:
利用消息中间件向边缘节点发送携带有数据查询条件的数据获取请求。The message middleware is used to send a data acquisition request carrying data query conditions to the edge node.
本发明实施例还提供了另一种数据获取方法，应用于边缘节点，边缘节点与至少一个用户节点连接，用户节点设置有PACS系统，方法包括：The embodiment of the present invention also provides another data acquisition method, which is applied to an edge node, the edge node is connected to at least one user node, and the user node is provided with a PACS system, and the method includes:
接收中心节点发送过来的携带有数据查询条件的数据获取请求；Receive a data acquisition request with data query conditions sent from the central node;
根据数据获取请求确定对应的用户节点；Determine the corresponding user node according to the data acquisition request;
利用数据查询条件从用户节点的PACS系统中查询并获取数据查询条件所对应的数据；Use the data query conditions to query and obtain the data corresponding to the data query conditions from the PACS system of the user node;
将数据发送给中心节点。Send data to the central node.
上述方案中，利用数据查询条件从用户节点的PACS系统中查询并获取数据查询条件所对应的数据，包括：In the above scheme, the data corresponding to the data query conditions are queried and obtained from the PACS system of the user node by using the data query conditions, including:
基于医学数字成像和通信协议利用数据查询条件从用户节点的PACS系统中查询并获取数据查询条件所对应的数据。Based on medical digital imaging and communication protocols, the data query conditions are used to query and obtain the data corresponding to the data query conditions from the PACS system of the user node.
上述方案中，医学数字成像和通信协议包括存储服务、查询服务、获取服务和移动服务。In the above solution, the medical digital imaging and communication protocol includes storage service, query service, acquisition service and mobile service.
本发明实施例还提供了第一种数据获取装置，应用于中心节点，中心节点与至少一个边缘节点连接，边缘节点与至少一个用户节点连接，用户节点设置有PACS系统，数据获取装置包括：The embodiment of the present invention also provides a first data acquisition device, which is applied to a central node, the central node is connected to at least one edge node, the edge node is connected to at least one user node, the user node is provided with a PACS system, and the data acquisition device includes:
第一确定模块，用于确定数据查询信息；其中，数据查询信息包含数据所在的用户节点信息和至少一个维度的数据查询条件；a first determining module, configured to determine data query information; wherein, the data query information includes user node information where the data is located and data query conditions of at least one dimension;
第二确定模块，用于根据用户节点信息确定用户节点信息所对应的边缘节点；a second determining module, configured to determine the edge node corresponding to the user node information according to the user node information;
发送模块，用于向边缘节点发送携带有数据查询条件的数据获取请求，并接收边缘节点根据数据查询条件返回的数据。The sending module is configured to send a data acquisition request carrying data query conditions to the edge node, and receive data returned by the edge node according to the data query conditions.
本发明实施例还提供了第二种数据获取装置，应用于边缘节点，边缘节点与至少一个用户节点连接，用户节点设置有PACS系统，数据获取装置包括：The embodiment of the present invention also provides a second data acquisition device, which is applied to an edge node, the edge node is connected to at least one user node, the user node is provided with a PACS system, and the data acquisition device includes:
接收模块，用于接收中心节点发送过来的携带有数据查询条件的数据获取请求；The receiving module is used to receive the data acquisition request with the data query condition sent from the central node;
确定模块，用于根据数据获取请求确定对应的用户节点；A determination module, used to determine the corresponding user node according to the data acquisition request;
查询模块，用于利用数据查询条件从用户节点的PACS系统中查询并获取数据查询条件所对应的数据；The query module is used to query and obtain the data corresponding to the data query conditions from the PACS system of the user node by using the data query conditions;
发送模块，用于将数据发送给中心节点。The sending module is used to send data to the central node.
本发明实施例还提供了一种数据获取系统，包括：中心节点，边缘节点，用户节点；其中，An embodiment of the present invention further provides a data acquisition system, including: a central node, an edge node, and a user node; wherein,
中心节点，包括上述第一种装置；A central node, including the above-mentioned first device;
边缘节点，包括上述第二种装置；An edge node, including the above-mentioned second device;
用户节点，用于存储数据。User node for storing data.
本发明实施例还提供了一种电子设备，包括：处理器和用于存储能够在处理器上运行的计算机程序的存储器；其中，An embodiment of the present invention also provides an electronic device, including: a processor and a memory for storing a computer program that can be executed on the processor; wherein,
处理器用于运行计算机程序时，执行上述任一方法的步骤。When the processor is used to run the computer program, the steps of any of the above methods are executed.
本发明实施例还提供了一种存储介质，存储介质中存储有计算机程序，计算机程序被处理器执行时，实现上述任一方法的步骤。An embodiment of the present invention further provides a storage medium, where a computer program is stored in the storage medium, and when the computer program is executed by a processor, the steps of any of the foregoing methods are implemented.
本发明实施例提供的数据获取方法、装置、电子设备和存储介质，确定数据查询信息；其中，数据查询信息包含数据所在的用户节点信息和至少一个维度的数据查询条件；根据用户节点信息确定用户节点信息所对应的边缘节点；向边缘节点发送携带有数据查询条件的数据获取请求，并接收边缘节点根据数据查询条件返回的数据。本发明实施例的方案中心节点利用边缘节点对用户节点存储的数据进行统一化管理，解决了以往用户节点数据管理混乱的问题，并且中心节点对用户节点进行统一的管理和调度，还能实现边缘节点从用户节点查询和获取数据时，能根据中心节点至少一个维度的数据查询条件多维度地从用户节点查询和获取数据。The data acquisition method, device, electronic device, and storage medium provided by the embodiments of the present invention determine data query information; wherein, the data query information includes user node information where the data is located and data query conditions of at least one dimension; the user is determined according to the user node information. The edge node corresponding to the node information; send a data acquisition request carrying data query conditions to the edge node, and receive the data returned by the edge node according to the data query conditions. In the solution of the embodiment of the present invention, the central node uses the edge nodes to uniformly manage the data stored by the user nodes, which solves the problem of confusion in the data management of the user nodes in the past, and the central node manages and schedules the user nodes in a unified manner. When the node queries and obtains data from the user node, it can query and obtain data from the user node in multiple dimensions according to the data query conditions of at least one dimension of the central node.
附图说明Description of drawings
图1为本发明实施例一数据获取方法的流程示意图；1 is a schematic flowchart of a data acquisition method according to an embodiment of the present invention;
图2为本发明实施例中一数据获取架构示意图；2 is a schematic diagram of a data acquisition architecture in an embodiment of the present invention;
图3为本发明实施例另一数据获取方法的流程示意图；3 is a schematic flowchart of another data acquisition method according to an embodiment of the present invention;
图4为本发明实施例一数据获取装置的结构示意图；4 is a schematic structural diagram of a data acquisition device according to Embodiment 1 of the present invention;
图5为本发明实施例另一数据获取装置的结构示意图；5 is a schematic structural diagram of another data acquisition apparatus according to an embodiment of the present invention;
图6为本发明实施例计算机设备的内部结构图。FIG. 6 is an internal structural diagram of a computer device according to an embodiment of the present invention.
具体实施方式Detailed ways
下面将结合附图及实施例对本发明作进一步详细的描述。The present invention will be described in further detail below with reference to the accompanying drawings and embodiments.
这里，在介绍本发明实施例方案之前，先介绍几个专有名词：Here, before introducing the solutions of the embodiments of the present invention, a few proper terms are introduced:
DICOM是医学图像和相关信息的国际标准(ISO 12052)。它定义了质量能满足临床需要的可用于数据交换的医学图像格式。DICOM is an international standard (ISO 12052) for medical images and related information. It defines a medical image format that can be used for data exchange with a quality that meets clinical needs.
PACS是应用在医院影像科室的系统，主要的任务就是把日常产生的各种医学影像(包括核磁，CT，超声，各种X光机，各种红外仪、显微仪等设备产生的图像)通过各种接口(模拟，DICOM，网络)以数字化的方式海量保存起来，当需要的时候在一定的授权下能够很快的调回使用，同时增加一些辅助诊断管理功能。它在各种影像设备间传输数据和组织存储数据具有重要作用。PACS is a system used in the imaging department of the hospital. The main task is to convert the various medical images (including nuclear magnetic resonance, CT, ultrasound, various X-ray machines, various infrared instruments, microscopes and other equipment generated images) Through various interfaces (analog, DICOM, network), it is stored in a large number in a digital way, and can be quickly recalled for use under certain authorization when needed, and some auxiliary diagnostic management functions are added at the same time. It plays an important role in transmitting data and organizing and storing data between various imaging devices.
消息中间件是基于队列与消息传递技术，在网络环境中为应用系统提供同步或异步、可靠的消息传输的支撑性软件系统。Message middleware is a supporting software system that provides synchronous or asynchronous and reliable message transmission for application systems in a network environment based on queue and message delivery technology.
本发明实施例提供了一种数据获取方法，应用于中心节点，所述中心节点与至少一个边缘节点连接，所述边缘节点与至少一个用户节点连接，所述用户节点设置有PACS系统，如图1所示，该方法包括：An embodiment of the present invention provides a data acquisition method, which is applied to a central node, the central node is connected to at least one edge node, the edge node is connected to at least one user node, and the user node is provided with a PACS system, as shown in the figure 1, the method includes:
步骤101：确定数据查询信息；其中，所述数据查询信息包含数据所在的用户节点信息和至少一个维度的数据查询条件；Step 101: Determine data query information; wherein, the data query information includes user node information where the data is located and data query conditions of at least one dimension;
步骤102：根据所述用户节点信息确定所述用户节点信息所对应的边缘节点；Step 102: Determine the edge node corresponding to the user node information according to the user node information;
步骤103：向所述边缘节点发送携带有所述数据查询条件的数据获取请求，并接收所述边缘节点根据所述数据查询条件返回的数据。Step 103: Send a data acquisition request carrying the data query condition to the edge node, and receive data returned by the edge node according to the data query condition.
具体地，所述中心节点可为多个分散的节点，多个分散的节点协调工作，能实现较好的负载均衡和高可用性。用户节点可为医院端PACS工作站。Specifically, the central node may be a plurality of distributed nodes, and the plurality of distributed nodes work in coordination, which can achieve better load balance and high availability. The user node can be a hospital-side PACS workstation.
实际应用时，在从用户节点查询和获取影像数据前，中心节点会先确定数据查询信息。该数据查询信息至少包含数据所在的用户节点信息和至少一个维度的数据查询条件。该数据查询条件可以为多维度的，且可以根据不同的查询要求灵活设置。具体地，该数据查询条件的维度可包括姓名、身份证号、性别、电话号码、用户编号和/或登记序号。当然，上述数据查询条件的维度还可以包含其他维度，上述所列举的维度仅作为其中一种示例。In practical applications, before querying and obtaining image data from user nodes, the central node will first determine the data query information. The data query information at least includes user node information where the data is located and data query conditions of at least one dimension. The data query conditions can be multi-dimensional, and can be flexibly set according to different query requirements. Specifically, the dimensions of the data query condition may include name, ID number, gender, phone number, user number and/or registration serial number. Of course, the dimensions of the above data query conditions may also include other dimensions, and the dimensions listed above are only one example.
进一步地，中心节点在向边缘节点发送数据获取请求时，可通过消息中间件发送。Further, when the central node sends the data acquisition request to the edge node, it can be sent through the message middleware.
在一实施例中，所述向所述边缘节点发送携带有所述数据查询条件的数据获取请求，包括：In an embodiment, the sending the data acquisition request carrying the data query condition to the edge node includes:
利用消息中间件向所述边缘节点发送携带有所述数据查询条件的数据获取请求。A data acquisition request carrying the data query condition is sent to the edge node by using the message middleware.
具体地，该消息中间件可为ActiveMQ、RabbitMQ、RocketMQ、Kafka、ZeroMQ等。Specifically, the message middleware may be ActiveMQ, RabbitMQ, RocketMQ, Kafka, ZeroMQ, and the like.
利用消息中间件下发数据获取请求，可以实现实时快速地下发指令，指令及时生效。且利用消息中间件下发数据获取请求，每次下发的数据获取请求可携带不同维度的数据查询条件，实现灵活多维度地查询和获取用户节点的数据。Using the message middleware to issue data acquisition requests, it is possible to quickly issue instructions in real time, and the instructions take effect in time. In addition, the data acquisition request is issued by the message middleware, and each data acquisition request issued can carry data query conditions of different dimensions, so as to realize flexible and multi-dimensional query and acquisition of user node data.
这里需要说明的是，在以往架构中，PACS服务器是通过固定维度的查询条件从PACS工作站中查询和获取数据，若要改变查询条件的维度，需要进行软件升级，且升级后的维度是固定的，不能改变。而本实施例中，中心节点通过消息中间件下发携带有不同维度数据查询条件的数据获取请求，可以实现灵活多维度地查询和获取用户节点的数据，无需进行软件升级，且满足不同场景下的DICOM医学影像数据的获取请求。It should be noted here that in the previous architecture, the PACS server queries and obtains data from the PACS workstation through query conditions of fixed dimensions. To change the dimension of query conditions, software upgrades are required, and the dimensions after the upgrade are fixed. ,unable to be changed. In this embodiment, the central node sends data acquisition requests that carry data query conditions of different dimensions through the message middleware, which can query and acquire the data of user nodes in a flexible and multi-dimensional manner, without software upgrade, and meet the requirements of different scenarios. DICOM medical image data acquisition request.
本实施例通过分布式系统部署，即设置中心节点与多个边缘节点连接，边缘节点与多个用户节点连接，利用上述架构实现中心节点和边缘节点对边端的用户节点进行统一的管理。另外，上述架构中，中心节点可根据用户的不同需求自定义设置多维度的DICOM医学影像数据查询和获取条件，并利用消息中间件下发到对应的边缘节点执行，通过中心节点进行统一调控，灵活多维度地查询和获取数据。This embodiment is deployed through a distributed system, that is, the central node is set to be connected to multiple edge nodes, and the edge nodes are connected to multiple user nodes, and the central node and edge nodes are used to implement unified management of user nodes at the edge by using the above architecture. In addition, in the above architecture, the central node can customize the multi-dimensional DICOM medical image data query and acquisition conditions according to the different needs of users, and use the message middleware to send it to the corresponding edge node for execution, and conduct unified control through the central node. Query and retrieve data flexibly and in multiple dimensions.
此外，参见图2，本申请还提供了一个实施例，完整详细介绍本申请的技术方案。In addition, referring to FIG. 2 , the present application also provides an embodiment, which completely introduces the technical solution of the present application in detail.
具体地，在本实施例中，设置多个中心节点，多个中心节点协同工作，多个中心节点根据医学结构化数据(可理解为数据库数据)主动发起获取DICOM医学影像数据的请求，并利用消息中间件下发给边缘节点，边缘节点接受请求并发起DICOM影像的传输通信，从用户节点的PACS端查询和获取数据。Specifically, in this embodiment, multiple central nodes are set up, and the multiple central nodes work cooperatively. The multiple central nodes actively initiate requests for obtaining DICOM medical image data according to medical structured data (which can be understood as database data), and use the The message middleware is sent to the edge node, and the edge node accepts the request and initiates the transmission communication of DICOM images, and queries and obtains data from the PACS side of the user node.
详细的查询和获取过程为：中心节点对于不同PACS端在具体实施部署时使用的多样化的不同规范的对于医学影像数据标准支持的情景(不同医院使用不同的标志来标识唯一一次检查，例如，使用检查实例唯一ID(study Instance Uid(0020,000D))、登记编号(Accession Number(0008,0050))、病人ID(Patient ID(0010,0020))等标志来标识唯一一次检查)，自定义配置查询条件维度，在需要获取DICOM医学影像时根据实际情况确定查询条件的维度，并将确定结果发送给边缘节点，边缘节点触发调用PACS系统进行DICOM影像的查询、获取以及存储。The detailed query and acquisition process is as follows: the central node uses the diverse and different specifications used by different PACS terminals during the specific implementation and deployment to support medical image data standards (different hospitals use different signs to identify a unique examination, for example, Use the examination instance unique ID (study Instance Uid(0020,000D)), registration number (Accession Number(0008,0050)), patient ID (Patient ID(0010,0020)) and other signs to identify a unique examination), custom Configure the dimension of the query condition, determine the dimension of the query condition according to the actual situation when obtaining DICOM medical images, and send the determination result to the edge node, and the edge node triggers the call to the PACS system to query, obtain and store DICOM images.
查询和获取DICOM影像时，中心节点会进行DICOM报文的组装，并通过消息中间件路由到边缘节点，边缘节点通过DICOM Q/R服务进行数据的查询和获取，实现不同查询维度查询和获取数据。When querying and obtaining DICOM images, the central node will assemble DICOM messages and route them to edge nodes through message middleware. Edge nodes query and obtain data through the DICOM Q/R service to achieve query and obtain data in different query dimensions. .
这里，DICOM Q/R是查询获取医疗影像的一组协议，包括查询服务C-find、获取服务C-get、移动服务C-move、存储服务C-store。利用DICOM协议的C-store、C-find、C-get\C-move服务可以实现对医学影像数据进行传输和统一存储，提高医学影像数据和医学结构化数据完整性。Here, DICOM Q/R is a set of protocols for querying and obtaining medical images, including query service C-find, acquisition service C-get, mobile service C-move, and storage service C-store. Using the C-store, C-find, C-get\C-move services of the DICOM protocol can realize the transmission and unified storage of medical image data, and improve the integrity of medical image data and medical structured data.
本实施例的方案能解决不同科室或者不同医院中从不同维度获取DICOM影像的问题。The solution of this embodiment can solve the problem of acquiring DICOM images from different dimensions in different departments or different hospitals.
本发明实施例提供的数据获取方法，确定数据查询信息；其中，数据查询信息包含数据所在的用户节点信息和至少一个维度的数据查询条件；根据用户节点信息确定用户节点信息所对应的边缘节点；向边缘节点发送携带有数据查询条件的数据获取请求，并接收边缘节点根据数据查询条件返回的数据。本发明实施例的方案中心节点利用边缘节点对用户节点存储的数据进行统一化管理，解决了以往用户节点数据管理混乱的问题，并且中心节点对用户节点进行统一的管理和调度，还能实现边缘节点从用户节点查询和获取数据时，能根据中心节点至少一个维度的数据查询条件多维地从用户节点查询和获取数据。In the data acquisition method provided by the embodiment of the present invention, data query information is determined; wherein, the data query information includes user node information where the data is located and data query conditions of at least one dimension; the edge node corresponding to the user node information is determined according to the user node information; Send a data acquisition request carrying data query conditions to the edge node, and receive data returned by the edge node according to the data query conditions. In the solution of the embodiment of the present invention, the central node uses the edge nodes to uniformly manage the data stored by the user nodes, which solves the problem of confusion in the data management of the user nodes in the past, and the central node manages and schedules the user nodes in a unified manner. When the node queries and obtains data from the user node, it can query and obtain data from the user node in multiple dimensions according to the data query conditions of at least one dimension of the central node.
本发明实施例还提供了另一种数据获取方法，应用于边缘节点，所述边缘节点与至少一个用户节点连接，所述用户节点设置有PACS系统，如图3所示，该方法包括：An embodiment of the present invention further provides another data acquisition method, which is applied to an edge node, where the edge node is connected to at least one user node, and the user node is provided with a PACS system. As shown in FIG. 3 , the method includes:
步骤301：接收所述中心节点发送过来的携带有数据查询条件的数据获取请求；Step 301: Receive a data acquisition request carrying data query conditions sent by the central node;
步骤302：根据所述数据获取请求确定对应的用户节点；Step 302: Determine the corresponding user node according to the data acquisition request;
步骤303：利用所述数据查询条件从所述用户节点的PACS系统中查询并获取所述数据查询条件所对应的数据；Step 303: query and obtain the data corresponding to the data query condition from the PACS system of the user node by using the data query condition;
步骤304：将所述数据发送给所述中心节点。Step 304: Send the data to the central node.
具体地，所述中心节点可为多个分散的节点，多个分散的节点协调工作，能实现较好的负载均衡和高可用性。用户节点可为医院端PACS工作站。Specifically, the central node may be a plurality of distributed nodes, and the plurality of distributed nodes work in coordination, which can achieve better load balance and high availability. The user node can be a hospital-side PACS workstation.
实际应用时，在从用户节点查询和获取影像数据前，中心节点会先确定数据查询信息。该数据查询信息至少包含数据所在的用户节点信息和至少一个维度的数据查询条件。该数据查询条件可以为多维度的，且可以根据不同的查询要求灵活设置。具体地，该数据查询条件的维度可包括姓名、身份证号、性别、电话号码、用户编号和/或登记序号。当然，上述数据查询条件的维度还可以包含其他维度，上述所列举的维度仅作为其中一种示例。In practical applications, before querying and obtaining image data from user nodes, the central node will first determine the data query information. The data query information at least includes user node information where the data is located and data query conditions of at least one dimension. The data query conditions can be multi-dimensional, and can be flexibly set according to different query requirements. Specifically, the dimensions of the data query condition may include name, ID number, gender, phone number, user number and/or registration serial number. Of course, the dimensions of the above data query conditions may also include other dimensions, and the dimensions listed above are only one example.
进一步地，中心节点在向边缘节点发送数据获取请求时，可通过消息中间件发送。Further, when the central node sends the data acquisition request to the edge node, it can be sent through the message middleware.
在一实施例中，所述向所述边缘节点发送携带有所述数据查询条件的数据获取请求，包括：In an embodiment, the sending the data acquisition request carrying the data query condition to the edge node includes:
利用消息中间件向所述边缘节点发送携带有所述数据查询条件的数据获取请求。A data acquisition request carrying the data query condition is sent to the edge node by using the message middleware.
具体地，该消息中间件可为ActiveMQ、RabbitMQ、RocketMQ、Kafka、ZeroMQ等。Specifically, the message middleware may be ActiveMQ, RabbitMQ, RocketMQ, Kafka, ZeroMQ, and the like.
利用消息中间件下发数据获取请求，可以实现实时快速地下发指令，指令及时生效。且利用消息中间件下发数据获取请求，每次下发的数据获取请求可携带不同维度的数据查询条件，实现灵活多维度地查询和获取用户节点的数据。Using the message middleware to issue data acquisition requests, it is possible to quickly issue instructions in real time, and the instructions take effect in time. In addition, the data acquisition request is issued by the message middleware, and each data acquisition request issued can carry data query conditions of different dimensions, so as to realize flexible and multi-dimensional query and acquisition of user node data.
这里需要说明的是，在以往架构中，PACS服务器是通过固定维度的查询条件从PACS工作站中查询和获取数据，若要改变查询条件的维度，需要进行软件升级，且升级后的维度是固定的，不能改变。而本实施例中，中心节点通过消息中间件下发携带有不同维度数据查询条件的数据获取请求，可以实现灵活多维度地查询和获取用户节点的数据，无需进行软件升级，且满足不同场景下的DICOM医学影像数据的获取请求。It should be noted here that in the previous architecture, the PACS server queries and obtains data from the PACS workstation through query conditions of fixed dimensions. To change the dimension of query conditions, software upgrades are required, and the dimensions after the upgrade are fixed. ,unable to be changed. In this embodiment, the central node sends data acquisition requests that carry data query conditions of different dimensions through the message middleware, which can query and acquire the data of user nodes in a flexible and multi-dimensional manner, without software upgrade, and meet the requirements of different scenarios. DICOM medical image data acquisition request.
本实施例通过分布式系统部署，即设置中心节点与多个边缘节点连接，边缘节点与多个用户节点连接，利用上述架构实现中心节点和边缘节点对边端的用户节点进行统一的管理。另外，上述架构中，中心节点可根据用户的不同需求自定义设置多维度的DICOM医学影像数据查询和获取条件，并利用消息中间件下发到对应的边缘节点执行，通过中心节点进行统一调控，灵活多维度地查询和获取数据。This embodiment is deployed through a distributed system, that is, the central node is set to be connected to multiple edge nodes, and the edge nodes are connected to multiple user nodes, and the central node and edge nodes are used to implement unified management of user nodes at the edge by using the above architecture. In addition, in the above architecture, the central node can customize the multi-dimensional DICOM medical image data query and acquisition conditions according to the different needs of users, and use the message middleware to send it to the corresponding edge node for execution, and conduct unified control through the central node. Query and retrieve data flexibly and in multiple dimensions.
此外，本申请还提供了一个实施例，完整详细介绍本申请的技术方案。In addition, the present application also provides an embodiment, which fully describes the technical solution of the present application in detail.
具体地，在本实施例中，设置多个中心节点，多个中心节点协同工作，多个中心节点根据医学结构化数据(可理解为数据库数据)主动发起获取DICOM医学影像数据的请求，并利用消息中间件下发给边缘节点，边缘节点接受请求并发起DICOM影像的传输通信，从用户节点的PACS端查询和获取数据。Specifically, in this embodiment, multiple central nodes are set up, and the multiple central nodes work cooperatively. The multiple central nodes actively initiate requests for obtaining DICOM medical image data according to medical structured data (which can be understood as database data), and use the The message middleware is sent to the edge node, and the edge node accepts the request and initiates the transmission communication of DICOM images, and queries and obtains data from the PACS side of the user node.
详细的查询和获取过程为：中心节点对于不同PACS端在具体实施部署时使用的多样化的不同规范的对于医学影像数据标准支持的情景(不同医院使用不同的标志来标识唯一一次检查，例如，使用检查实例唯一ID(study Instance Uid(0020,000D))、登记编号(Accession Number(0008,0050))、病人ID(Patient ID(0010,0020))等标志来标识唯一一次检查)，自定义配置查询条件维度，在需要获取DICOM医学影像时根据实际情况确定查询条件的维度，并将确定结果发送给边缘节点，边缘节点触发调用PACS系统进行DICOM影像的查询、获取以及存储。The detailed query and acquisition process is as follows: the central node uses the diverse and different specifications used by different PACS terminals during the specific implementation and deployment to support medical image data standards (different hospitals use different signs to identify a unique examination, for example, Use the examination instance unique ID (study Instance Uid(0020,000D)), registration number (Accession Number(0008,0050)), patient ID (Patient ID(0010,0020)) and other signs to identify a unique examination), custom Configure the dimension of the query condition, determine the dimension of the query condition according to the actual situation when obtaining DICOM medical images, and send the determination result to the edge node, and the edge node triggers the call to the PACS system to query, obtain and store DICOM images.
查询和获取DICOM影像时，中心节点会进行DICOM报文的组装，并通过消息中间件路由到边缘节点，边缘节点通过DICOM Q/R服务进行数据的查询和获取，实现不同查询维度查询和获取数据。When querying and obtaining DICOM images, the central node will assemble DICOM messages and route them to edge nodes through message middleware. Edge nodes query and obtain data through the DICOM Q/R service to achieve query and obtain data in different query dimensions. .
这里，DICOM Q/R是查询获取医疗影像的一组协议，包括C-find、C-get、C-move、C-store。利用DICOM协议的C-store、C-find、C-get\C-move服务可以实现对医学影像数据进行传输和统一存储，提高医学影像数据和医学结构化数据完整性。Here, DICOM Q/R is a set of protocols for querying and obtaining medical images, including C-find, C-get, C-move, and C-store. Using the C-store, C-find, C-get\C-move services of the DICOM protocol can realize the transmission and unified storage of medical image data, and improve the integrity of medical image data and medical structured data.
本实施例的方案能解决不同科室或者不同医院中从不同维度获取DICOM影像的问题。The solution of this embodiment can solve the problem of acquiring DICOM images from different dimensions in different departments or different hospitals.
本发明实施例提供的数据获取方法，接收所述中心节点发送过来的携带有数据查询条件的数据获取请求；根据所述数据获取请求确定对应的用户节点；利用所述数据查询条件从所述用户节点的PACS系统中查询并获取所述数据查询条件所对应的数据；将所述数据发送给所述中心节点。本发明实施例的方案中心节点利用边缘节点对用户节点存储的数据进行统一化管理，解决了以往用户节点数据管理混乱的问题，并且中心节点对用户节点进行统一的管理和调度，还能实现边缘节点从用户节点查询和获取数据时，能根据中心节点至少一个维度的数据查询条件多维度地从用户节点查询和获取数据。In the data acquisition method provided by the embodiment of the present invention, a data acquisition request with data query conditions sent from the central node is received; a corresponding user node is determined according to the data acquisition request; Query and obtain the data corresponding to the data query condition in the PACS system of the node; and send the data to the central node. In the solution of the embodiment of the present invention, the central node uses the edge nodes to uniformly manage the data stored by the user nodes, which solves the problem of confusion in the data management of the user nodes in the past, and the central node manages and schedules the user nodes in a unified manner. When the node queries and obtains data from the user node, it can query and obtain data from the user node in multiple dimensions according to the data query conditions of at least one dimension of the central node.
为了实现本发明实施例的方法，本发明实施例还提供了第一种数据获取装置，应用于中心节点，所述中心节点与至少一个边缘节点连接，所述边缘节点与至少一个用户节点连接，所述用户节点设置有PACS系统，如图4所示，数据获取装置400包括：第一确定模块401、第二确定模块402和发送模块403；其中，In order to implement the method of the embodiment of the present invention, the embodiment of the present invention further provides a first data acquisition device, which is applied to a central node, the central node is connected to at least one edge node, and the edge node is connected to at least one user node, The user node is provided with a PACS system. As shown in FIG. 4 , the data acquisition device 400 includes: a first determination module 401, a second determination module 402 and a sending module 403; wherein,
第一确定模块401，用于确定数据查询信息；其中，所述数据查询信息包含数据所在的用户节点信息和至少一个维度的数据查询条件；The first determining module 401 is configured to determine data query information; wherein, the data query information includes user node information where the data is located and data query conditions of at least one dimension;
第二确定模块402，用于根据所述用户节点信息确定所述用户节点信息所对应的边缘节点；A second determining module 402, configured to determine the edge node corresponding to the user node information according to the user node information;
发送模块403，用于向所述边缘节点发送携带有所述数据查询条件的数据获取请求，并接收所述边缘节点根据所述数据查询条件返回的数据。The sending module 403 is configured to send a data acquisition request carrying the data query condition to the edge node, and receive data returned by the edge node according to the data query condition.
实际应用时，第一确定模块401、第二确定模块402和发送模块403可由数据获取装置中的处理器实现。In practical application, the first determining module 401, the second determining module 402 and the sending module 403 may be implemented by a processor in the data acquisition apparatus.
需要说明的是：上述实施例提供的数据获取装置在获取数据时，仅以上述各程序模块的划分进行举例说明，实际应用时，可以根据需要而将上述处理分配由不同的程序模块完成，即将终端的内部结构划分成不同的程序模块，以完成以上描述的全部或者部分处理。另外，上述实施例提供的数据获取装置与数据获取方法实施例属于同一构思，其具体实现过程详见方法实施例，这里不再赘述。It should be noted that: when the data acquisition device provided in the above embodiment acquires data, only the division of the above program modules is used as an example for illustration. In actual application, the above processing can be allocated to different program modules to complete according to needs. The internal structure of the terminal is divided into different program modules to complete all or part of the processing described above. In addition, the data acquisition device and the data acquisition method provided in the above embodiments belong to the same concept, and the specific implementation process thereof is detailed in the method embodiment, which will not be repeated here.
为了实现本发明实施例的方法，本发明实施例还提供了第二种数据获取装置，应用于边缘节点，所述边缘节点与至少一个用户节点连接，所述用户节点设置有PACS系统，如图5所示，数据获取装置500包括：接收模块501、确定模块502、查询模块503和发送模块504；其中，In order to implement the method of the embodiment of the present invention, the embodiment of the present invention further provides a second data acquisition device, which is applied to an edge node, the edge node is connected to at least one user node, and the user node is provided with a PACS system, as shown in the figure 5, the data acquisition device 500 includes: a receiving module 501, a determining module 502, a querying module 503 and a sending module 504; wherein,
接收模块501，用于接收所述中心节点发送过来的携带有数据查询条件的数据获取请求；A receiving module 501, configured to receive a data acquisition request carrying data query conditions sent by the central node;
确定模块502，用于根据所述数据获取请求确定对应的用户节点；A determination module 502, configured to determine a corresponding user node according to the data acquisition request;
查询模块503，用于利用所述数据查询条件从所述用户节点的PACS系统中查询并获取所述数据查询条件所对应的数据；The query module 503 is used to query and obtain the data corresponding to the data query condition from the PACS system of the user node by using the data query condition;
发送模块504，用于将所述数据发送给所述中心节点。A sending module 504, configured to send the data to the central node.
实际应用时，接收模块501、确定模块502、查询模块503和发送模块504可由数据获取装置中的处理器实现。In practical application, the receiving module 501, the determining module 502, the querying module 503 and the sending module 504 may be implemented by a processor in the data acquisition device.
需要说明的是：上述实施例提供的数据获取装置在获取数据时，仅以上述各程序模块的划分进行举例说明，实际应用时，可以根据需要而将上述处理分配由不同的程序模块完成，即将终端的内部结构划分成不同的程序模块，以完成以上描述的全部或者部分处理。另外，上述实施例提供的数据获取装置与数据获取方法实施例属于同一构思，其具体实现过程详见方法实施例，这里不再赘述。It should be noted that: when the data acquisition device provided in the above embodiment acquires data, only the division of the above program modules is used as an example for illustration. In actual application, the above processing can be allocated to different program modules to complete according to needs. The internal structure of the terminal is divided into different program modules to complete all or part of the processing described above. In addition, the data acquisition device and the data acquisition method provided in the above embodiments belong to the same concept, and the specific implementation process thereof is detailed in the method embodiment, which will not be repeated here.
另外，本实施例还提供了一种数据获取系统，包括：中心节点，边缘节点，用户节点；其中，In addition, this embodiment also provides a data acquisition system, including: a central node, an edge node, and a user node; wherein,
中心节点，包括上述第一种装置；A central node, including the above-mentioned first device;
边缘节点，包括上述第二种装置；An edge node, including the above-mentioned second device;
用户节点，用于存储数据。User node for storing data.
基于上述程序模块的硬件实现，且为了实现本发明实施例的方法，本发明实施例还提供了一种电子设备(计算机设备)。具体地，在一个实施例中，该计算机设备可以是终端，其内部结构图可以如图6所示。该计算机设备包括通过系统总线连接的处理器A01、网络接口A02、显示屏A04、输入装置A05和存储器(图中未示出)。其中，该计算机设备的处理器A01用于提供计算和控制能力。该计算机设备的存储器包括内存储器A03和非易失性存储介质A06。该非易失性存储介质A06存储有操作系统B01和计算机程序B02。该内存储器A03为非易失性存储介质A06中的操作系统B01和计算机程序B02的运行提供环境。该计算机设备的网络接口A02用于与外部的终端通过网络连接通信。该计算机程序被处理器A01执行时以实现上述任意一项实施例的方法。该计算机设备的显示屏A04可以是液晶显示屏或者电子墨水显示屏，该计算机设备的输入装置A05可以是显示屏上覆盖的触摸层，也可以是计算机设备外壳上设置的按键、轨迹球或触控板，还可以是外接的键盘、触控板或鼠标等。Based on the hardware implementation of the above program modules, and in order to implement the method of the embodiment of the present invention, the embodiment of the present invention further provides an electronic device (computer device). Specifically, in one embodiment, the computer device may be a terminal, and its internal structure diagram may be as shown in FIG. 6 . The computer equipment includes a processor A01, a network interface A02, a display screen A04, an input device A05 and a memory (not shown in the figure) connected by a system bus. Among them, the processor A01 of the computer device is used to provide computing and control capabilities. The memory of the computer device includes an internal memory A03 and a non-volatile storage medium A06. The nonvolatile storage medium A06 stores an operating system B01 and a computer program B02. The internal memory A03 provides an environment for the operation of the operating system B01 and the computer program B02 in the nonvolatile storage medium A06. The network interface A02 of the computer device is used to communicate with an external terminal through a network connection. When the computer program is executed by the processor A01, the method of any one of the above-mentioned embodiments is implemented. The display screen A04 of the computer equipment can be a liquid crystal display screen or an electronic ink display screen, and the input device A05 of the computer equipment can be a touch layer covered on the display screen, or a button, a trackball or a touch screen set on the shell of the computer equipment. It can also be an external keyboard, trackpad or mouse.
本领域技术人员可以理解，图6中示出的结构，仅仅是与本申请方案相关的部分结构的框图，并不构成对本申请方案所应用于其上的计算机设备的限定，具体的计算机设备可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。Those skilled in the art can understand that the structure shown in FIG. 6 is only a block diagram of a partial structure related to the solution of the present application, and does not constitute a limitation on the computer equipment to which the solution of the present application is applied. Include more or fewer components than shown in the figures, or combine certain components, or have a different arrangement of components.
本发明实施例提供的设备，设备包括处理器、存储器及存储在存储器上并可在处理器上运行的程序，处理器执行程序时实现上述任意一项实施例的方法。In the device provided by the embodiment of the present invention, the device includes a processor, a memory, and a program stored in the memory and executable on the processor, and the processor implements the method of any one of the foregoing embodiments when the processor executes the program.
本领域内的技术人员应明白，本申请的实施例可提供为方法、系统、或计算机程序产品。因此，本申请可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本申请可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。As will be appreciated by those skilled in the art, the embodiments of the present application may be provided as a method, a system, or a computer program product. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, etc.) having computer-usable program code embodied therein.
本申请是参照根据本申请实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。The present application is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the present application. It will be understood that each flow and/or block in the flowchart illustrations and/or block diagrams, and combinations of flows and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to the processor of a general purpose computer, special purpose computer, embedded processor or other programmable data processing device to produce a machine such that the instructions executed by the processor of the computer or other programmable data processing device produce Means for implementing the functions specified in a flow or flow of a flowchart and/or a block or blocks of a block diagram.
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program instructions may also be stored in a computer-readable memory capable of directing a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory result in an article of manufacture comprising instruction means, the instructions The apparatus implements the functions specified in the flow or flow of the flowcharts and/or the block or blocks of the block diagrams.
这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program instructions can also be loaded on a computer or other programmable data processing device to cause a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented process such that The instructions provide steps for implementing the functions specified in the flow or blocks of the flowcharts and/or the block or blocks of the block diagrams.
在一个典型的配置中，计算设备包括一个或多个处理器(CPU)、输入/输出接口、网络接口和内存。In a typical configuration, a computing device includes one or more processors (CPUs), input/output interfaces, network interfaces, and memory.
存储器可能包括计算机可读介质中的非永久性存储器，随机存取存储器(RAM)和/或非易失性内存等形式，如只读存储器(ROM)或闪存(flashRAM)。存储器是计算机可读介质的示例。The memory may include non-persistent memory in computer readable media, random access memory (RAM) and/or non-volatile memory in the form of, for example, read only memory (ROM) or flash memory (flashRAM). Memory is an example of a computer-readable medium.
计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括，但不限于相变内存(PRAM)、静态随机存取存储器(SRAM)、动态随机存取存储器(DRAM)、其他类型的随机存取存储器(RAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、快闪记忆体或其他内存技术、只读光盘只读存储器(CD-ROM)、数字多功能光盘(DVD)或其他光学存储、磁盒式磁带，磁带磁磁盘存储或其他磁性存储设备或任何其他非传输介质，可用于存储可以被计算设备访问的信息。按照本文中的界定，计算机可读介质不包括暂存电脑可读媒体(transitorymedia)，如调制的数据信号和载波。Computer-readable media includes both persistent and non-permanent, removable and non-removable media, and storage of information may be implemented by any method or technology. Information may be computer readable instructions, data structures, modules of programs, or other data. Examples of computer storage media include, but are not limited to, phase-change memory (PRAM), static random access memory (SRAM), dynamic random access memory (DRAM), other types of random access memory (RAM), read only memory (ROM), Electrically Erasable Programmable Read Only Memory (EEPROM), Flash Memory or other memory technology, Compact Disc Read Only Memory (CD-ROM), Digital Versatile Disc (DVD) or other optical storage, Magnetic tape cassettes, magnetic tape magnetic disk storage or other magnetic storage devices or any other non-transmission medium that can be used to store information that can be accessed by a computing device. As defined herein, computer-readable media does not include transitory computer-readable media, such as modulated data signals and carrier waves.
可以理解，本发明实施例的存储器可以是易失性存储器或者非易失性存储器，也可包括易失性和非易失性存储器两者。其中，非易失性存储器可以是只读存储器(ROM，ReadOnly Memory)、可编程只读存储器(PROM，Programmable Read-Only Memory)、可擦除可编程只读存储器(EPROM，Erasable Programmable Read-Only Memory)、电可擦除可编程只读存储器(EEPROM，Electrically Erasable Programmable Read-Only Memory)、磁性随机存取存储器(FRAM，ferromagnetic random access memory)、快闪存储器(Flash Memory)、磁表面存储器、光盘、或只读光盘(CD-ROM，Compact Disc Read-Only Memory)；磁表面存储器可以是磁盘存储器或磁带存储器。易失性存储器可以是随机存取存储器(RAM，RandomAccess Memory)，其用作外部高速缓存。通过示例性但不是限制性说明，许多形式的RAM可用，例如静态随机存取存储器(SRAM，Static Random Access Memory)、同步静态随机存取存储器(SSRAM，Synchronous Static Random Access Memory)、动态随机存取存储器(DRAM，Dynamic Random Access Memory)、同步动态随机存取存储器(SDRAM，SynchronousDynamic Random Access Memory)、双倍数据速率同步动态随机存取存储器(DDRSDRAM，Double Data Rate Synchronous Dynamic Random Access Memory)、增强型同步动态随机存取存储器(ESDRAM，Enhanced Synchronous Dynamic Random Access Memory)、同步连接动态随机存取存储器(SLDRAM，SyncLink Dynamic Random Access Memory)、直接内存总线随机存取存储器(DRRAM，Direct Rambus Random Access Memory)。本发明实施例描述的存储器旨在包括但不限于这些和任意其它适合类型的存储器。It can be understood that the memory in this embodiment of the present invention may be a volatile memory or a non-volatile memory, and may also include both a volatile memory and a non-volatile memory. Among them, the non-volatile memory may be a read-only memory (ROM, ReadOnly Memory), a programmable read-only memory (PROM, Programmable Read-Only Memory), an erasable programmable read-only memory (EPROM, Erasable Programmable Read-Only Memory) Memory), Electrically Erasable Programmable Read-Only Memory (EEPROM, Electrically Erasable Programmable Read-Only Memory), Magnetic Random Access Memory (FRAM, ferromagnetic random access memory), Flash Memory, Magnetic Surface Memory, Optical disk, or Compact Disc Read-Only Memory (CD-ROM); the magnetic surface memory can be a magnetic disk memory or a magnetic tape memory. The volatile memory may be a random access memory (RAM, Random Access Memory), which is used as an external cache memory. By way of example and not limitation, many forms of RAM are available, such as Static Random Access Memory (SRAM), Synchronous Static Random Access Memory (SSRAM), Dynamic Random Access Memory Memory (DRAM, Dynamic Random Access Memory), Synchronous Dynamic Random Access Memory (SDRAM, SynchronousDynamic Random Access Memory), Double Data Rate Synchronous Dynamic Random Access Memory (DDRSDRAM, Double Data Rate Synchronous Dynamic Random Access Memory), Enhanced Synchronous Dynamic Random Access Memory (ESDRAM, Enhanced Synchronous Dynamic Random Access Memory), Synchronous Link Dynamic Random Access Memory (SLDRAM, SyncLink Dynamic Random Access Memory), Direct Memory Bus Random Access Memory (DRRAM, Direct Rambus Random Access Memory) . The memory described in the embodiments of the present invention is intended to include, but not be limited to, these and any other suitable types of memory.
还需要说明的是，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、商品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、商品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括要素的过程、方法、商品或者设备中还存在另外的相同要素。It should also be noted that the terms "comprising", "comprising" or any other variation thereof are intended to encompass a non-exclusive inclusion such that a process, method, article or device comprising a series of elements includes not only those elements, but also Other elements not expressly listed, or which are inherent to such a process, method, article of manufacture, or apparatus are also included. Without further limitation, an element qualified by the phrase "comprising a..." does not preclude the presence of additional identical elements in the process, method, article of manufacture or apparatus that includes the element.
以上仅为本申请的实施例而已，并不用于限制本申请。对于本领域技术人员来说，本申请可以有各种更改和变化。凡在本申请的精神和原理之内所作的任何修改、等同替换、改进等，均应包含在本申请的权利要求范围之内。The above are merely examples of the present application, and are not intended to limit the present application. Various modifications and variations of this application are possible for those skilled in the art. Any modification, equivalent replacement, improvement, etc. made within the spirit and principle of this application shall be included within the scope of the claims of this application.
Claims (10)
1. A data acquisition method is applied to a central node, the central node is connected with at least one edge node, the edge node is connected with at least one user node, and the user node is provided with an image archiving and communication system, and the method comprises the following steps:
determining data query information; the data query information comprises user node information of data and data query conditions of at least one dimension;
determining an edge node corresponding to the user node information according to the user node information;
and sending a data acquisition request carrying the data query condition to the edge node, and receiving data returned by the edge node according to the data query condition.
2. The method according to claim 1, wherein the sending the data acquisition request carrying the data query condition to the edge node comprises:
and sending a data acquisition request carrying the data query condition to the edge node by using message middleware.
3. A data acquisition method is applied to an edge node, the edge node is connected with at least one user node, the user node is provided with an image archiving and communication system, and the edge node is connected with a central node, and the method comprises the following steps:
receiving a data acquisition request carrying a data query condition sent by the central node;
determining a corresponding user node according to the data acquisition request;
inquiring and acquiring data corresponding to the data inquiry condition from the image archiving and communication system of the user node by using the data inquiry condition;
and sending the data to the central node.
4. The method according to claim 3, wherein the querying and obtaining the data corresponding to the data query condition from the image archiving and communication system of the user node using the data query condition comprises:
and inquiring and acquiring data corresponding to the data inquiry condition from the image archiving and communication system of the user node by utilizing the data inquiry condition based on the medical digital imaging and communication protocol.
5. The method of claim 4, wherein the medical digital imaging and communications protocols include storage services, query services, acquisition services, and mobile services.
6. A data acquisition device is applied to a central node, the central node is connected with at least one edge node, the edge node is connected with at least one user node, the user node is provided with an image filing and communication system, and the data acquisition device comprises:
the first determining module is used for determining data query information; the data query information comprises user node information of data and data query conditions of at least one dimension;
a second determining module, configured to determine, according to the user node information, an edge node corresponding to the user node information;
and the sending module is used for sending a data acquisition request carrying the data query condition to the edge node and receiving data returned by the edge node according to the data query condition.
7. The utility model provides a data acquisition device which characterized in that is applied to the edge node, the edge node is connected with at least one user node, user node is provided with image and files and communication system, data acquisition device includes:
the receiving module is used for receiving a data acquisition request carrying data query conditions and sent by the central node;
a determining module, configured to determine a corresponding user node according to the data acquisition request;
the query module is used for querying and acquiring data corresponding to the data query condition from the image archiving and communication system of the user node by using the data query condition;
and the sending module is used for sending the data to the central node.
8. A data acquisition system, comprising: a central node, an edge node and a user node; wherein,
the central node comprising the apparatus of claim 6;
the edge node comprising the apparatus of claim 7;
and the user node is used for storing data.
9. An electronic device, comprising: a processor and a memory for storing a computer program capable of running on the processor; wherein,
the processor is adapted to perform the steps of the method of any one of claims 1 to 5 when running the computer program.
10. A storage medium having a computer program stored thereon, wherein the computer program, when executed by a processor, performs the steps of the method of any one of claims 1 to 5.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111040951.8A CN113761246B (en) | 2021-09-06 | 2021-09-06 | Data acquisition method, device, electronic device and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111040951.8A CN113761246B (en) | 2021-09-06 | 2021-09-06 | Data acquisition method, device, electronic device and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113761246A true CN113761246A (en) | 2021-12-07 |
| CN113761246B CN113761246B (en) | 2024-11-15 |
Family
ID=78793248
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111040951.8A Active CN113761246B (en) | 2021-09-06 | 2021-09-06 | Data acquisition method, device, electronic device and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113761246B (en) |
Cited By (1)
* Cited by examiner, † Cited by third party| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115129751A (en) * | 2022-06-27 | 2022-09-30 | 杭州数梦工场科技有限公司 | A data query method, device, electronic device and storage medium |
Citations (13)
* Cited by examiner, † Cited by third party| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105306573A (en) * | 2015-11-03 | 2016-02-03 | 浙江格林蓝德信息技术有限公司 | Method for scheduling original data of medical image, and medical image transmission system |
| CN106997418A (en) * | 2016-01-22 | 2017-08-01 | 广东福地新视野光电技术有限公司 | A method and system for long-distance transmission of medical images |
| CN109783512A (en) * | 2018-12-13 | 2019-05-21 | 平安科技（深圳）有限公司 | Data processing method, device, computer equipment and storage medium |
| CN110335667A (en) * | 2019-05-22 | 2019-10-15 | 平安国际智慧城市科技股份有限公司 | Medical image management method, device, system and storage medium |
| CN110457544A (en) * | 2019-08-14 | 2019-11-15 | 上海联影医疗科技有限公司 | A kind of data capture method, system, electronic equipment and storage medium |
| CN110990456A (en) * | 2019-11-29 | 2020-04-10 | 山东爱城市网信息技术有限公司 | Block chain-based information reading and converting method, device and medium |
| CN111180051A (en) * | 2019-12-31 | 2020-05-19 | 健康蓝图(北京)科技有限公司 | Medical image data processing method and device |
| CN111581627A (en) * | 2020-05-11 | 2020-08-25 | 北京精准沟通传媒科技股份有限公司 | Data processing method and device and electronic equipment |
| CN111883233A (en) * | 2020-07-14 | 2020-11-03 | 上海商汤智能科技有限公司 | Image acquisition method and device, electronic equipment and storage medium |
| CN112015820A (en) * | 2020-09-01 | 2020-12-01 | 杭州欧若数网科技有限公司 | Method, system, electronic device and storage medium for implementing distributed graph database |
| CN112035424A (en) * | 2020-08-25 | 2020-12-04 | 北京金山云网络技术有限公司 | Data query method, device and system, electronic equipment and storage medium |
| WO2021004384A1 (en) * | 2019-07-09 | 2021-01-14 | 阿里巴巴集团控股有限公司 | Content delivery network, data processing method, apparatus and device, and storage medium |
| CN112416964A (en) * | 2020-11-17 | 2021-02-26 | 深圳依时货拉拉科技有限公司 | Data processing method, device and system, computer equipment and computer readable storage medium |
-
2021
- 2021-09-06 CN CN202111040951.8A patent/CN113761246B/en active Active
Patent Citations (13)
* Cited by examiner, † Cited by third party| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105306573A (en) * | 2015-11-03 | 2016-02-03 | 浙江格林蓝德信息技术有限公司 | Method for scheduling original data of medical image, and medical image transmission system |
| CN106997418A (en) * | 2016-01-22 | 2017-08-01 | 广东福地新视野光电技术有限公司 | A method and system for long-distance transmission of medical images |
| CN109783512A (en) * | 2018-12-13 | 2019-05-21 | 平安科技（深圳）有限公司 | Data processing method, device, computer equipment and storage medium |
| CN110335667A (en) * | 2019-05-22 | 2019-10-15 | 平安国际智慧城市科技股份有限公司 | Medical image management method, device, system and storage medium |
| WO2021004384A1 (en) * | 2019-07-09 | 2021-01-14 | 阿里巴巴集团控股有限公司 | Content delivery network, data processing method, apparatus and device, and storage medium |
| CN110457544A (en) * | 2019-08-14 | 2019-11-15 | 上海联影医疗科技有限公司 | A kind of data capture method, system, electronic equipment and storage medium |
| CN110990456A (en) * | 2019-11-29 | 2020-04-10 | 山东爱城市网信息技术有限公司 | Block chain-based information reading and converting method, device and medium |
| CN111180051A (en) * | 2019-12-31 | 2020-05-19 | 健康蓝图(北京)科技有限公司 | Medical image data processing method and device |
| CN111581627A (en) * | 2020-05-11 | 2020-08-25 | 北京精准沟通传媒科技股份有限公司 | Data processing method and device and electronic equipment |
| CN111883233A (en) * | 2020-07-14 | 2020-11-03 | 上海商汤智能科技有限公司 | Image acquisition method and device, electronic equipment and storage medium |
| CN112035424A (en) * | 2020-08-25 | 2020-12-04 | 北京金山云网络技术有限公司 | Data query method, device and system, electronic equipment and storage medium |
| CN112015820A (en) * | 2020-09-01 | 2020-12-01 | 杭州欧若数网科技有限公司 | Method, system, electronic device and storage medium for implementing distributed graph database |
| CN112416964A (en) * | 2020-11-17 | 2021-02-26 | 深圳依时货拉拉科技有限公司 | Data processing method, device and system, computer equipment and computer readable storage medium |
Non-Patent Citations (1)
* Cited by examiner, † Cited by third party| Title |
|---|
| 熊尚华 等: "医联体智慧影像云协同平台建设及应用", 中国数字医学, vol. 15, no. 3, 31 December 2020 (2020-12-31), pages 95 - 97 * |
Cited By (1)
* Cited by examiner, † Cited by third party| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115129751A (en) * | 2022-06-27 | 2022-09-30 | 杭州数梦工场科技有限公司 | A data query method, device, electronic device and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113761246B (en) | 2024-11-15 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US9704207B2 (en) | 2017-07-11 | Administering medical digital images in a distributed medical digital image computing environment with medical image caching |
| US9104985B2 (en) | 2015-08-11 | Processing system using metadata for administering a business transaction |
| CN101803293B (en) | 2015-09-09 | Healthcare semantic interoperability platform |
| US9734476B2 (en) | 2017-08-15 | Dynamically allocating data processing components |
| CN110311973B (en) | 2021-06-01 | A multi-tenant-oriented image cloud service system and method |
| US8458202B2 (en) | 2013-06-04 | Methods and systems for consolidating medical information |
| US20120221728A1 (en) | 2012-08-30 | Administering Medical Digital Images With Intelligent Analytic Execution Of Workflows |
| US20120221346A1 (en) | 2012-08-30 | Administering Medical Digital Images In A Distributed Medical Digital Image Computing Environment |
| JPH11239165A (en) | 1999-08-31 | Medical network system |
| CN110704200B (en) | 2024-11-22 | Method and device for converting calling interface |
| US8856365B2 (en) | 2014-10-07 | Computer-implemented method, computer system and computer readable medium |
| US20130018694A1 (en) | 2013-01-17 | Dynamically Allocating Business Workflows |
| US20200185095A1 (en) | 2020-06-11 | Plug-and-play medical interoperability and data liquidity platform |
| CN111180051A (en) | 2020-05-19 | Medical image data processing method and device |
| CN113761246B (en) | 2024-11-15 | Data acquisition method, device, electronic device and storage medium |
| WO2019043462A1 (en) | 2019-03-07 | Systems and methods for creating automated interface transmission between heterogeneous systems in an enterprise ecosystem |
| US11568972B2 (en) | 2023-01-31 | Workflow platform to integrate with an electronic health record system |
| US10629310B2 (en) | 2020-04-21 | Systems and methods for facilitating communication of health information |
| CN109992988A (en) | 2019-07-09 | A data rights management method and device |
| EP3041187B1 (en) | 2022-05-04 | Method and mobile device for communicating information between a mobile device and an enterprise system |
| US7792921B2 (en) | 2010-09-07 | Metadata endpoint for a generic service |
| Ghosh et al. | 2022 | Cloud computing infrastructure in healthcare industry |
| US20160063077A1 (en) | 2016-03-03 | Data brokering system for fulfilling data requests to multiple data providers |
| US12182157B2 (en) | 2024-12-31 | System and method of execution context processing with addressable universal data location |
| US20090287667A1 (en) | 2009-11-19 | Data processing method and apparatus thereof |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| 2021-12-07 | PB01 | Publication | |
| 2021-12-07 | PB01 | Publication | |
| 2021-12-24 | SE01 | Entry into force of request for substantive examination | |
| 2021-12-24 | SE01 | Entry into force of request for substantive examination | |
| 2024-11-15 | GR01 | Patent grant | |
| 2024-11-15 | GR01 | Patent grant |