Server for controlling data transmission through data pipeline and operation method thereof
AssigneeSamsung Electronics Co., Ltd.
InventorsSeungyeol Hyun, Inki Hwang, Jemin Kim
Life of this patent
Estimating the term…
Abstract
Provided are a server for controlling data transmission through a data pipeline, and an operation method thereof. A pipeline control server is configured to create and dispose a data broker including a message queue, between a data source and a data sink according to a registration event of the data sink, and to provision an infra of the data pipeline, and an operation method thereof. A pipeline control server is configured to schedule an operation time point of a data dispersal pipeline that transmits data to a data sink based on an operation event of a data ingestion pipeline that transmits data from a data source to a data broker, and an operation method thereof.
Claims15
A method of controlling data transmission through a data pipeline, the method comprising:
- detecting a registration event of a data sink for receiving data from a data source;
- based on the registration event of the data sink, obtaining parameter information including at least one of a maximum connectable number of data sources, a number of data sinks, a region in which a cloud service providing server is located, or a number of data sinks for each region;
- determining, based on the parameter information, a provisioning region of a data broker including a message queue;
- and
- provisioning, based on the provisioning region of the data broker, a pipeline infrastructure (infra) for executing the data pipeline that performs movement and transformation of data between the data source and the data broker and between the data broker and the data sink.
A server for controlling data transmission through a data pipeline, the server comprising:
- a network interface configured to transmit data to and receive data from a cloud service providing server;
- a memory storing a program including one or more instructions;
- and
- a processor configured to execute the one or more instructions to:
- detect a registration event of a data sink for receiving data from a data source of the cloud service providing server,
- based on the registration event of the data sink, obtain parameter information including at least one of a maximum connectable number of data sources, a number of data sinks, a region in which the cloud service providing server is located, or a number of data sinks for each region.
- determine, based on the parameter information, a provisioning region of a data broker including a message queue, and
- provision, based on the provisioning region of the data broker, a pipeline infrastructure (infra) for executing the data pipeline that performs a movement and transformation of data between the data source and the data broker and between the data broker and the data sink.
A computer program product including a non-transitory computer-readable storage medium storing instructions that when executed by a server, cause the server to perform a method of controlling data transmission through a data pipeline, the method comprising:
- detecting a registration event of a data sink for receiving data from a data source,
- based on the registration event of the data sink, obtaining parameter information including at least one of a maximum connectable number of data sources, a number of data sinks, a region in which a cloud service providing server is located, or the number of data sinks for each region,
- determining a provisioning region of a data broker including a message queue based on the parameter information, and
- provisioning, based on the provisioning region of the data broker, a pipeline infra for executing the data pipeline that performs a movement and transformation of data between the data source and the data broker and between the data broker and the data sink.
Dependencies are inferred from the claim text.