СПОСОБ СБОРА ДАННЫХ И ДИСПЕТЧЕР СЕТЕВЫХ ЭЛЕМЕНТОВ Российский патент 2025 года по МПК H04L41/00 

Перекрестная ссылка на родственную заявку

[0001] По настоящей заявке испрашивается приоритет согласно заявке на патент КНР №202010512670.7, поданной 8 июня 2020 г., полное содержание которой включено в настоящий документ посредством ссылки.

Область техники, к которой относится изобретение

[0002] Варианты осуществления настоящего изобретения относятся к области техники сетей связи и, в частности, к способу сбора данных и диспетчеру сетевых элементов.

Предпосылки создания изобретения

[0003] Диспетчер сети (диспетчер сетевых элементов, такой как диспетчер беспроводной сети) осуществляет управление сетью путем анализа данных с помощью различных модулей, например, путем анализа данных сигнализации, анализа данных измерений, анализа отслеживания пользователей, анализа данных спектра и т.п., и эти данные собираются от сетевого элемента.

[0004] Когда определенному модулю (модулю услуги, то есть абонентской стороне) нужны данные, модуль, которому нужны данные, передает задачу сбора данных соответствующему сетевому элементу, такому как контроллер радиосети (Radio Network Controller, RNC), усовершенствованный узел В (Evolved Node В, eNodeB), базовая станция 5-го поколения (5^th Generation, 5G) (5G Base Station, gNB) и т.п., сетевой элемент собирает данные после приема задачи сбора, а затем передает собранные данные в соответствующий модуль по различным каналам, таким как канал протокола управления передачей (Transmission Control Protocol, TCP), канал протокола передачи файлов FTP (File Transfer Protocol, FTP), сообщение простого протокола управления сетью (Simple Network Management Protocol, SNMP) и т.п., и модуль после приема данных далее обрабатывает их в соответствии со своими потребностями.

[0005] Сбор данных от элементов сети вышеуказанным способом излишне занимает полосы частот и вычислительные ресурсы, что приводит к трате сетевых ресурсов.

Сущность изобретения

[0006] В первом аспекте варианты осуществления настоящего изобретения предлагают модуль сбора данных, применимый в диспетчере сетевых элементов и включающий: прием, от первой абонентской стороны, первого запроса подписки, используемого для подписки на первые данные, причем первые данные представляют собой конкретные данные в пределах будущего первого периода времени; определение, имеется ли в настоящее время совпадающая задача сбора, причем данные, запрошенные для сбора совпадающей задачей сбора, содержат по меньшей мере первые данные; в случае, когда имеется совпадающая задача сбора, получение потока данных в соответствии с совпадающей задачей сбора, получение первых данных из потока данных и передачу первых данных первой абонентской стороне; и в случае, когда нет совпадающей задачи сбора, создание первой задачи сбора в соответствии с первым запросом подписки, причем первая задача сбора используется для запроса сбора первых данных, получение потока данных в соответствии по меньшей мере с первой задачей сбора, получение первых данных из потока данных и передачу первых данных первой абонентской стороне.

[0007] Во втором аспекте варианты осуществления настоящего изобретения предлагают диспетчер сетевых элементов, содержащий: модуль приема, первый модуль определения, первый модуль обработки и второй модуль обработки.

[0008] Модуль приема сконфигурирован для приема первого запроса подписки от первой абонентской стороны. Первый запрос подписки используется для подписки на первые данные, а первые данные представляют собой конкретные данные в пределах будущего первого периода времени.

[0009] Первый модуль определения сконфигурирован для определения, имеется ли в настоящее время совпадающая задача сбора. Данные, запрошенные для сбора совпадающей задачей сбора, содержат по меньшей мере первые данные.

[00010] Первый модуль обработки сконфигурирован так, чтобы, когда имеется совпадающая задача сбора, получать поток данных в соответствии с совпадающей задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне.

[00011] Второй модуль обработки сконфигурирован так, чтобы, когда нет совпадающей задачи сбора, создавать первую задачу сбора в соответствии с первым запросом подписки, при этом первая задача сбора используется для запроса сбора первых данных, получать поток данных в соответствии по меньшей мере с первой задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне.

Краткое описание чертежей

[00012] Чертежи вариантов осуществления настоящего изобретения:

[00013] Фиг. 1 представляет собой блок-схему способа сбора данных, предусмотренного в варианте осуществления настоящего изобретения.

[00014] Фиг. 2 представляет собой блок-схему некоторых операций в способе сбора данных, предусмотренном в варианте осуществления настоящего изобретения.

[00015] Фиг. 3 представляет собой блок-схему некоторых операций в способе сбора данных, предусмотренном в варианте осуществления настоящего изобретения.

[00016] Фиг. 4 представляет структурную схему диспетчера сетевых элементов, предусмотренного в варианте осуществления настоящего изобретения.

Подробное описание вариантов осуществления изобретения

[00017] Чтобы специалисты в данной области техники могли лучше понять технические решения вариантов осуществления настоящего изобретения, способ сбора данных и диспетчер сетевых элементов, предлагаемые в вариантах осуществления настоящего изобретения, будут подробно описаны ниже со ссылками на чертежи.

[00018] Варианты осуществления настоящего изобретения будут описаны более подробно ниже со ссылкой на чертежи, но проиллюстрированные варианты осуществления могут быть воплощены в различных формах, и варианты осуществления настоящего изобретения не должны толковаться как ограниченные вариантами осуществления, изложенными в настоящем раскрытии. Проиллюстрированные варианты осуществления представлены только для того, чтобы сделать настоящее раскрытие максимально полным и всесторонним, а также дать возможность специалистам в данной области техники полностью понять объем настоящего изобретения.

[00019] Чертежи вариантов осуществления настоящего изобретения используются для обеспечения понимания вариантов осуществления настоящего изобретения и составляют часть описания, используются для пояснения настоящего изобретения вместе с вариантами осуществления настоящего изобретения и не ограничивают настоящее изобретение. Технические признаки и преимущества вариантов осуществления настоящего изобретения станут более понятными для специалистов в данной области техники по прочтении описания подробных примеров осуществления изобретения со ссылкой на чертежи.

[00020] Варианты осуществления настоящего изобретения могут быть описаны со ссылкой на вид сверху и/или вид в поперечном сечении посредством идеализированной схемы настоящего изобретения. Однако примеры иллюстраций могут быть изменены в соответствии с технологией производства и/или допусками.

[00021] В случае отсутствия конфликта различные варианты осуществления настоящего изобретения и признаки вариантов осуществления могут быть объединены друг с другом.

[00022] Термины, используемые в настоящем описании, предназначены только для описания конкретных вариантов осуществления и не предназначены для ограничения настоящего изобретения. Выражение "и/или", используемое в настоящем раскрытии, включает любые и все комбинации одного или более связанных перечисленных элементов. Используемые в настоящем раскрытии формы единственного числа предназначены также для включения форм множественного числа, если в контексте явно не указано иное. Используемые в настоящем описании термины "включают", "состоят из" указывают на наличие конкретных признаков, целых чисел, шагов, операций, элементов и/или компонентов, но не исключают наличия или добавления одного или более других признаков, целых чисел, шагов, операций, элементов, компонентов и/или их групп.

[00023] Если не указано иное, все используемые здесь термины (включая технические и научные термины) имеют то же значение, которое обычно понимают специалисты в данной области техники. Также следует понимать, что такие термины, как те, которые определены в общих словарях, должны толковаться как имеющие значения, соответствующие значениям, используемым в соответствующей области техники и в известном уровне техники для настоящего изобретения, и не будут толковаться как имеющие идеализированные или чрезмерно формальные значения, если это прямо не указано в настоящем раскрытии.

[00024] Варианты осуществления настоящего изобретения не ограничены вариантами осуществления, показанными на чертежах, но включают варианты осуществления, в которых конфигурации изменены на основе производственного процесса. Соответственно, области, показанные на чертежах, имеют схематические атрибуты, и формы областей, показанных на чертежах, не являются ограничительными.

[00025] В первом аспекте, со ссылкой на фиг.1, варианты осуществления настоящего изобретения предлагают способ сбора данных, который применим в диспетчере сетевых элементов и включает следующие шаги S101-S104.

[00026] S101: первый запрос подписки принимают от первой абонентской стороны, причем первый запрос подписки используют для подписки на первые данные, а первые данные представляют собой конкретные данные в пределах будущего первого периода времени.

[00027] Диспетчер сетевых элементов принимает запрос подписки от определенной абонентской стороны (т.е. определенного модуля услуги, такого как модуль анализа данных); запрос подписки используют для резервирования определенных данных, и эти данные представляют собой конкретные данные в пределах определенного периода времени в будущем, то есть данные в течение периода времени после текущего момента времени. Например, текущий момент времени 10:00, запрос подписки может относиться только к данным в течение определенного периода времени после 10:00, например, к данным между 10:30 и 11:00, но не может относиться к данным в период времени до 10:00, например, не может относиться к данным между 9:00 и 9:30.

[00028] Для простоты в настоящем описании абонентская сторона является первой абонентской стороной, запрос подписки, принимаемый диспетчером сетевых элементов от первой абонентской стороны, является первым запросом подписки, первый запрос подписки используется для подписки на первые данные, а первые данные являются конкретными данными в пределах будущего первого периода времени.

[00029] То есть принимаемый в настоящее время запрос подписки или обрабатываемый в настоящее время запрос подписки является первым запросом подписки, а первые запросы подписки в другие моменты времени или в других процессах обработки являются другими запросами подписки. Конечно, абонентская сторона, соответствующая первому запросу подписки, является первой абонентской стороной, которая может быть другой в другие моменты времени или в других процессах обработки.

[00030] Первые данные относятся к определенному типу данных в определенном сетевом элементе в течение будущего определенного периода времени (т.е. первого периода времени), например, могут быть данными отчета об измерении, которые соответствуют определенным условиям и имеют порядковый номер 256 на базовой станции 5G.

[00031] Например, первый запрос подписки может включать список данных подписки, тип сетевого элемента подписки, область подписки, объект подписки, тип подписки, элемент подписки, параметр подписки и период времени подписки:

[00032] Список данных подписки представляет собой порядковый номер сетевого элемента, которому принадлежат данные подписки, порядковый номер является идентификатором сетевого элемента, и разные сетевые элементы одного и того же типа имеют разные порядковые номера.

[00033] Тип сетевого элемента подписки - это тип сетевого элемента, которому принадлежат данные подписки, например, RNC, eNodeB, gNB и т.п., разные сетевые элементы разных типов могут иметь одинаковый порядковый номер, например, сетевой элемент, тип которого - RNC, а порядковый номер - 256, отличается от сетевого элемента, тип которого - eNodeB, а порядковый номер - 256.

[00034] Область подписки - это местоположение сетевого элемента, в котором находятся данные подписки, например, данные беспроводного модуля с идентификатором ID=1 или идентификатором ID=1 соты дуплексного режима с временным разделением (Time Division Duplex, TDD) сетевого элемента, тип которого - RNC, а порядковый номер - 256, оба - ID беспроводного модуля и ID соты TDD - представляют собой конкретные параметры местоположения данных, посредством которых можно определить конкретные данные подписки.

[00035] Объект подписки - тип объекта данных подписки, например, сота, беспроводное устройство и т.п.

[00036] Тип подписки - тип, к которому принадлежат данные подписки или использование данных, например, данные сигнализации, данные измерений, данные отслеживания пользователей, данные частотного спектра, данные проверки производительности, данные отслеживания деталей вызовов, данные получения программного обеспечения сигнализации, данные о производительности и т.п.

[00037] Элемент подписки - это конкретный параметр данных подписки, например, порт (S1/UU/X2).

[00038] Параметр подписки - это конкретный параметр данных подписки, например, параметр - это глубина отслеживания, а значение - это максимальный уровень.

[00039] Период времени подписки является первым периодом времени, который может быть периодом времени только после текущего момента времени.

[00040] S102: определяют, имеется ли в настоящее время совпадающая задача сбора, и данные, запрошенные для сбора совпадающей задачей сбора, включают по меньшей мере первые данные.

[00041] После приема первого запроса подписки диспетчер сетевых элементов должен установить первую задачу сбора в соответствии с первым запросом подписки, при этом первую задачу сбора используют для сбора первых данных в течение первого периода времени. Однако, поскольку диспетчер сетевых элементов может принимать также другие запросы подписки до получения первого запроса подписки, диспетчер сетевых элементов может установить множество других задач сбора, и может иметь место совпадающая задача сбора среди этих установленных задач сбора, то есть данные, требуемые для сбора, включают задачу сбора первых данных. Следовательно, прежде чем будет установлена первая задача сбора, сначала определяют, имеется ли совпадающая задача сбора среди установленных задач сбора.

[00042] Данные, запрошенные для сбора, включают первые данные, что означает, что данные, запрошенные для сбора, включают все данные, запрошенные для сбора в соответствии с первым запросом подписки, то есть данные, запрошенные для сбора с помощью совпадающей задачи сбора включают по меньшей мере конкретные данные в пределах будущего первого периода времени, которые запрашиваются для сбора в первом запросе подписки, при этом, конечно, данные, запрошенные для сбора с помощью совпадающей задачи сбора, могут также включать другие данные, которые не относятся к первым данным.

[00043] Наличие совпадающей задачи сбора в текущих установленных задачах сбора может быть определено посредством определения наличия следующей задачи сбора среди установленных задач сбора, у которой список данных подписки, тип сетевого элемента подписки, область подписки, объект подписки, тип подписки, элемент подписки, параметр подписки и период времени подписки данных, запрашиваемых для сбора этой задачей сбора, полностью совпадает со списком данных подписки, типом сетевого элемента подписки, областью подписки, объектом подписки, типом подписки, элементом подписки, параметром подписки и периодом времени подписки в первом запросе подписки; или диапазоны списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки данных, запрошенных для сбора этой задачей сбора, превышают диапазоны списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки в первом запросе подписки.

[00044] Определение наличия совпадающей задачи сбора среди текущих установленных задач сбора может включать следующее:

[00045] 1. Определение наличия сетевого элемента для подписки, то есть определение типа сетевого элемента для подписки и списка данных подписки, например, определение, имеется ли задача сбора для сетевого элемента, тип которого RNC и порядковый номер равен 256, если нет, то это указывает на то, что нет совпадающей задачи сбора, и, таким образом, последующее определение можно не продолжать;

[00046] 2. Определение наличия области подписки, то есть дальнейшее определение, имеется ли задача сбора, которая включает область подписки в первом запросе подписки, или имеется ли область подписки, совпадающая с областью подписки в первом запросе подписки, из задач сбора для сетевого элемента подписки в первом запросе подписки, если нет, то это указывает, что нет совпадающей задачи сбора, и, таким образом, последующее определение можно не продолжать;

[00047] 3. Определение наличия объекта подписки, то есть дальнейшее определение, имеется ли задача сбора, которая имеет объект подписки, соответствующий объекту подписки в первом запросе подписки, или содержит объект подписки в первом запросе подписки, среди задач сбора, которые были определены на предыдущих двух шагах (то есть результаты определения предыдущих двух шагов являются оба "имеется/да"), если нет, то это указывает на то, что нет совпадающей задачи сбора, и, таким образом, последующее определение можно не продолжать;

[00048] 4. Определение наличия типа подписки, то есть дальнейшее определение наличия задачи сбора, которая имеет тип подписки, совпадающий с типом подписки в первом запросе подписки, или содержит тип подписки в первом запросе подписки, среди задач сбора, которые были определены на предыдущих трех шагах (т.е. результаты определения трех предыдущих шагов являются все "имеется/да"), если нет, то это указывает на то, что совпадающей задачи сбора нет, и, таким образом, последующее определение можно не продолжать;

[00049] 5. Определение наличия элемента подписки, то есть дальнейшее определение, имеется ли задача сбора, которая имеет элемент подписки, совпадающий с элементом подписки в первом запросе подписки, или содержит элемент подписки в первом запросе подписки, среди задач сбора, которые были определены на предыдущих четырех шагах (то есть результаты определения предыдущих четырех шагов все "имеется/да"), если нет, то это указывает на то, что совпадающей задачи сбора нет, и, таким образом, последующее определение можно не продолжать;

[00050] 6. Определение наличия параметра подписки, то есть дальнейшее определение, имеется ли задача сбора, которая имеет параметр подписки, совпадающий с параметром подписки в первом запросе подписки, или содержит параметр подписки в первом запросе подписки, среди задач сбора, которые были определены на предыдущих пяти шагах (то есть результаты определения предыдущих пяти шагов все "имеется/да"), если нет, то это указывает на то, что совпадающей задачи сбора нет, и, таким образом, последующее определение можно не продолжать;

[00051] 7. Определение наличия периода времени подписки, то есть определение, имеется ли задача сбора, которая включает период времени подписки (то есть первый период времени) в первом запросе подписки, среди задач сбора, которые были определены на всех предыдущих шагах (то есть результаты определения всех предыдущих шагов все "имеется/да"), и, если это так, задача сбора является совпадающей задачи сбора.

[00052] Конечно, можно использовать и другие последовательности определения, если можно в конечном счете определить, имеется ли совпадающая задача сбора. Последовательность определения в данном документе относится к последовательности выполнения связанного определения по списку данных подписки, типу сетевого элемента подписки, области подписки, объекту подписки, типу подписки, элементу подписки, параметру подписки и периоду времени подписки.

[00053] S103: в случае, когда имеется совпадающая задача сбора, поток данных получают в соответствии с совпадающей задачей сбора, и первые данные получают из потока данных и передают первой абонентской стороне.

[00054] В случае, когда диспетчер сетевых элементов определяет, что в настоящее время имеется совпадающая задача сбора, диспетчеру сетевых элементов не нужно устанавливать новую задачу сбора (то есть первую задачу сбора) и нужно только получить (или отфильтровать) из потока данных, собираемых из совпадающей задачи сбора, часть, принадлежащую к первым данным, когда совпадающая задача сбора начинает собирать данные, и передать эту часть первой абонентской стороне.

[00055] Конечно, как только все задачи сбора, включая совпадающую задачу сбора, будут завершены, соответствующие задачи сбора удаляют.

[00056] Например, диспетчер сетевых элементов принимает запрос 1 подписки в предыдущий момент, и необработанный запрос подписки включает только запрос 1 подписки, при этом запрос 1 подписки выглядит следующим образом.

[00057] Задача 1 сбора, установленная в соответствии с запросом 1 подписки, выглядит следующим образом.

[00058] Первый запрос подписки выглядит следующим образом.

[00059] startTime и endTime представляют времена начала и окончания подписки, соответственно, а первый период времени находится между ними.

[00060] Путем сравнения списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки устанавливают, что запрашиваемые данные, которые должны быть собраны первым запросом подписки, являются частью данных, запрошенных для сбора посредством запроса 1 подписки, который ранее получен диспетчером сетевых элементов, поэтому соответствующая задача 1 сбора является совпадающей задачей сбора, то есть не нужно устанавливать новую задачу сбора для первого запроса подписки, и только соответствующие данные должны быть получены из данных, собираемых задачей 1 сбора, и переданы первой абонентской стороне.

[00061] S104: в случае, когда нет совпадающей задачи сбора, первую задачу сбора создают в соответствии с первым запросом подписки, причем первую задачу сбора используют для запроса сбора первых данных, поток данных получают в соответствии с первым запросом подписки, первые данные получают из потока данных и передают первой абонентской стороне.

[00062] В случае, когда диспетчер сетевых элементов определяет, что в настоящее время нет совпадающей задачи сбора, диспетчеру сетевых элементов необходимо создать первую задачу сбора в соответствии с первым запросом подписки, при этом первую задачу сбора используют для запроса сбора по меньшей мере части первых данных. Когда первая задача сбора запрашивает сбор всех первых данных, диспетчер сетевых элементов собирает данные в соответствии с первой задачей сбора, получает первые данные из потока данных, полученного в соответствии с первой задачей сбора, и передает первые данные первой абонентской стороне. Когда первая задача сбора запрашивает сбор части первых данных вместо всех первых данных, диспетчеру сетевых элементов необходимо не только получить часть первых данных из потока данных, которые получают и собирают в соответствии с первой задачей сбора, но также необходимо получить (или отфильтровать) собранные другие части первых данных из потока данных, полученные в соответствии с другими задачами сбора, чтобы получить полные первые данные и передать первые данные первой абонентской стороне.

[00063] В некоторых связанных технологиях, если для разных модулей услуги требуются одни и те же данные, например, как модулю А услуги, так и модулю В услуги требуются данные D, то как модуль А услуги, так и модуль В услуги передают задачи сбора данных для сбора данных D соответствующему сетевому элементу, и поскольку соответствующий сетевой элемент получает две задачи сбора данных, несмотря на то, что запрашиваемые для сбора данные одни и те же, данные по-прежнему должны быть собраны дважды и соответственно переданы в модуль А услуги и модуль В услуги, так что повторный сбор данных приводит к трате полос частот сети.

[00064] В способе сбора данных согласно вариантам осуществления настоящего изобретения, когда принимают новый запрос подписки, повторный сбор данных сокращается посредством определения того, повторяются ли данные, предварительно определенные запросом подписки, с данными, предварительно определенными ранее принятым запросом подписки, что позволяет избежать траты сетевых ресурсов.

[00065] В некоторых вариантах осуществления изобретения, как показано на фиг.2, создание первой задачи сбора в соответствии с первым запросом подписки (S104) может включать шаги S1041-S1043.

[00066] S1041: определяют, имеется ли в настоящее время пересекающаяся задача сбора, причем первые данные включают пересекающиеся данные, которые принадлежат к данным, запрошенным для сбора пересекающейся задачей сбора, и отличающиеся данные, которые не принадлежат к данным, запрошенным для сбора пересекающейся задачей сбора.

[00067] В случае, когда диспетчер сетевых элементов не обнаруживает

совпадающую задачу сбора среди установленных задач сбора, диспетчер сетевых элементов определяет, в соответствии с первым запросом подписки, имеется ли пересекающаяся задача сбора среди установленных в настоящее время задач сбора.

[00068] Пересекающаяся задача сбора относится к тому, что данные, запрошенные для сбора задачей сбора, пересекаются с первыми данными, то есть в первых данных есть данные, которые включены в данные, запрошенные для сбора пересекающейся задачей сбора, а также в первых данных есть данные, которые не включены в данные, запрошенные для сбора пересекающейся задачей сбора.

[00069] Данные в первых данных, которые включены в данные, запрошенные для сбора пересекающейся задачей сбора, являются пересекающимися данными, а данные в первых данных, которые не включены в данные, запрошенные для сбора пересекающейся задачей сбора, представляют собой отличающиеся данные, при этом пересекающиеся данные и отличающиеся данные вместе образуют полные первые данные.

[00070] Определение наличия пересекающейся задачи сбора в настоящее время может включать: определение, имеется ли задача сбора, в которой каждый из списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки данных, запрошенных для сбора задачей сбора, совпадает или пересекается с соответствующим одним из списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки в первом запросе подписки.

[00071] В варианте осуществления последовательность определения наличия в настоящее время пересекающейся задачи сбора данных может быть совпадающей с последовательностью определения наличия совпадающей задачи сбора данных на шаге S102.

[00072] Последовательность определения здесь относится к последовательности выполнения связанного определения в отношении списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки.

[00073] S1042: в случае, когда имеется пересекающаяся задача сбора, создают первую задачу сбора для запроса сбора отличающихся данных, получают поток данных в соответствии с пересекающейся задачей сбора и первой задачей сбора, получают первые данные из потока данных и передают их первой абонентской стороне.

[00074] В случае, когда диспетчер сетевых элементов определяет наличие пересекающейся задачи сбора, диспетчер сетевых элементов создает первую задачу сбора, при этом первую задачу сбора используют для запроса сбора части первых данных, которая не включена в данные, запрошенные для сбора пересекающейся задачей сбора, т.е. отличающихся данных. Когда первая задача сбора начинает сбор данных, диспетчер сетевых элементов получает отличающиеся данные (т.е. все собранные данные) из потока данных, который собирают и получают в соответствии с первой задачей сбора, и передает отличающиеся данные первой абонентской стороне. Когда пересекающаяся задача сбора начинает собирать данные, диспетчер сетевых элементов получает (или отфильтровывает) из потока данных, полученного в соответствии с пересекающейся задачей сбора, данные из первых данных, которые включены в данные, запрошенные для сбора пересекающейся задачей сбора, то есть пересекающиеся данные, и передает пересекающиеся данные первой абонентской стороне.

[00075] Конечно, может быть множество пересекающихся задач сбора, данные, запрошенные для сбора множеством пересекающихся задач сбора, соответственно включают данные, принадлежащие к первым данным (т.е. пересекающиеся данные), и эти пересекающиеся данные могут просто формировать все первые данные, то есть множество частей пересекающихся данных могут быть объединены в полные первые данные, так что нет необходимости создавать первую задачу сбора, и необходимо только получать пересекающиеся данные из потоков данных, которые получены в соответствии с этими пересекающимися задачами сбора, когда эти пересекающиеся задачи сбора начинают собирать данные, и все эти части пересекающихся данных передают первой абонентской стороне.

[00076] Например, диспетчер сетевых элементов принимает запрос 2 подписки в предыдущий момент, а необработанный запрос подписки включает только запрос 2 подписки, и запрос 2 подписки выглядит следующим образом.

[00077] Задача 2 сбора, установленная в соответствии с запросом 2 подписки, выглядит следующим образом.

[00078] Первый запрос подписки выглядит следующим образом.

[00079] Путем сравнения списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки установлено, что запрашиваемые данные, которые должны быть собраны первым запросом подписки, представляют собой часть данных, запрошенных для сбора с помощью запроса 2 подписки, которые ранее были получены диспетчером сетевых элементов, поэтому соответствующая задача 2 сбора является пересекающейся задачей сбора.

[00080] В то же время необходимо создать первую задачу сбора, причем первую задачу сбора используют для сбора данных из первых данных, которые не принадлежат к данным, которые требуется собирать пересекающейся задачей сбора, то есть отличающихся данных, и, соответственно, первая задача сбора выглядит следующим образом.

[00081] Когда пересекающаяся задача сбора (т.е. задача 2 сбора) начинает сбор данных, пересекающиеся данные извлекают из потока данных, полученного в соответствии с задачей 2 сбора, и пересекающиеся данные передают первой абонентской стороне. Конечно, когда первая задача сбора начинает собирать данные, данные, которые собирают и получают в соответствии с первой задачей сбора, также должны быть переданы первой абонентской стороне.

[00082] S1043: в случае, когда нет пересекающейся задачи сбора, создают первую задачу сбора для запроса сбора первых данных, получают поток данных в соответствии с первой задачей сбора, получают первые данные из потока данных и передают их первой абонентской стороне.

[00083] В случае, когда диспетчер сетевых элементов определяет, что нет пересекающейся задачи сбора, диспетчер сетевых элементов должен создать первую задачу сбора, и первую задачу сбора используют для запроса сбора всех первых данных. Когда первая задача сбора начинает сбор данных, первые данные извлекают из потока данных в соответствии с первой задачей сбора и передают первой абонентской стороне.

[00084] Например, диспетчер сетевых элементов принимает запрос 3 подписки в предыдущий момент, а необработанный запрос подписки включает только запрос 3 подписки. Запрос 3 подписки выглядит следующим образом.

[00085] Задача 3 сбора, установленная в соответствии с запросом 3 подписки, выглядит следующим образом.

[00086] Первый запрос подписки выглядит следующим образом.

[00087] Путем сравнения списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки установлено, что запрашиваемые данные, которые должны быть собраны первым запросом подписки, не пересекаются с или полностью отличаются от данных, запрошенных для сбора с помощью запроса подписки, которые ранее были получены диспетчером сетевых элементов, так что должна быть установлена первая задача сбора в соответствии с первым запросом подписки, и первая задача сбора может быть следующей.

[00088] Когда первая задача сбора начинает сбор данных, диспетчер сетевых элементов получает первые данные из потока данных в соответствии с первой задачей сбора и передает первые данные первой абонентской стороне.

[00089] Посредством определения того, имеется ли пересекающаяся задача сбора, повторный сбор данных дополнительно сокращается. То есть в случае, когда часть первых данных собирается другими задачами сбора, необходимо собрать только оставшуюся часть первых данных, что дополнительно уменьшает потери сетевых ресурсов, вызванные повторным сбором одних и тех же данных.

[00090] В некоторых вариантах осуществления изобретения получение первых данных из потока данных и передача первых данных первой абонентской стороне включают: декодирование потока данных, получение объекта данных, включающего первые данные, получение первых данных из объекта данных и передачу первых данных первой абонентской стороне.

[00091] После приема потока данных, полученного в соответствии с задачей сбора (всеми задачами сбора, включая совпадающую задачу сбора, пресекающуюся задачу сбора и первую задачу сбора), диспетчер сетевых элементов должен декодировать поток данных. Это связано с тем, что поток данных, полученный в соответствии с задачей сбора, передается посредством протокола, так что поток собранных данных имеет заголовок протокола. Поток собранных данных необходимо декодировать, а заголовок протокола потока данных необходимо удалить, чтобы получить оставшуюся часть данных, то есть объект данных. Поскольку поток данных, собранных в соответствии с задачей сбора, включает первые данные, объект данных, естественно, также включает первые данные. После того как объект данных получен, первые данные получают из объекта данных и передают первой абонентской стороне.

[00092] Например, конкретный состав данных, собранных задачей сбора, показан в следующей таблице.

[00093] Объект данных после декодирования показан в следующей таблице.

[00094] Благодаря единообразному декодированию данных можно избежать траты сетевых ресурсов, вызванной повторным декодированием после того, как разные абонентские стороны принимают одни и те же данные.

[00095] В некоторых вариантах осуществления первый запрос подписки содержит тип данных.

[000100] Декодирование потока данных и получение объекта данных, включающего первые данные, включают: декодирование потока данных и получение объекта данных, типом данных которого является тип данных в первом запросе подписки, и объект данных включает первые данные.

[000101] Первый запрос подписки содержит тип данных, а тип данных, требуемый основным модулем услуги (то есть абонентской стороной), в основном включает три типа, то есть исходный кодовый поток (то есть оставшийся объект данных после удаления заголовка протокола), сводно декодированные данные (объект данных, полученный после выполнения сводного декодирования исходного кодового потока, то есть необходимо декодировать заголовок платформы сетевого элемента, заголовок идентификатора продукта и заголовок информации услуги, а часть тела данных не нужно декодировать) и подробно декодированные данные (объект данных, полученный после выполнения подробного декодирования сводно декодированных данных, то есть все части, включая тело данных, должны быть декодированы).

[000102] Таким образом, тип данных во всех запросах подписки является одним из трех типов данных, и тип данных в первом запросе подписки, конечно, является одним из этих трех типов данных.

[000103] После получения потока данных в соответствии с задачей сбора (всех задач сбора, включая совпадающую задачу сбора, пересекающуюся задачу сбора и первую задачу сбора) диспетчер сетевых элементов декодирует поток данных в соответствии с типом данных в соответствующем запросе подписки, получает объект данных, тип данных которого соответствует типу данных в соответствующем запросе подписки, и передает объект данных соответствующей абонентской стороне. Например, диспетчер сетевых элементов соответствующим образом декодирует поток данных, полученный в соответствии с первой задачей сбора, получает объект данных, типом данных которого является тип данных в первом запросе подписки, и передает объект данных первой абонентской стороне.

[000104] В варианте осуществления изобретения, когда тип данных в первом запросе подписки представляет собой сводно декодированные данные, в случае, когда имеется совпадающая задача сбора, декодируют поток данных, полученный в соответствии с первой задачей сбора, получают объект данных, типом данных которого являются сводно декодированные данные; первые данные получают из полученного объекта данных и передают первой абонентской стороне. В случае, когда есть пересекающаяся задача сбора и первая задача сбора, поток данных, полученный в соответствии с пересекающейся задачей сбора и первой задачей сбора, декодируют, получают объект данных, типом данных которого являются сводно декодированные данные, первые данные получают из полученного объекта данных и передают первой абонентской стороне; и в случае, когда имеется только первая задача сбора, поток данных, полученный в соответствии с первой задачей сбора, декодируют; получают объект данных, типом данных которого являются сводно декодированные данные, полученный объект данных представляет собой первые данные, и объект данных передают первой абонентской стороне.

[000105] Диспетчер сетевых элементов единообразно декодирует данные, последовательно декодирует данные различных требуемых типов данных и передает данные по мере необходимости, так что обеспечиваются управление данными и их передача.

[000106] В некоторых формах осуществления изобретения, как показано на фиг.3, декодирование потока данных, получение объекта данных, тип данных которого является типом данных в первом запросе подписки, причем объект данных включает первые данные, получение первых данных из объекта данных и передача первых данных первой абонентской стороне могут включать следующие шаги S201-S204.

[000107] S201: декодируют поток данных и получают объект данных, тип данных которого представляет собой исходный кодовый поток.

[000108] S202: декодируют объект данных, тип данных которого представляет собой исходный кодовый поток, и получают объект данных, тип данных которого является сводно декодированными данными.

[000109] S203: декодируют объект данных, тип данных которого представляет собой сводно декодированные данные, и получают объект данных, тип данных которого представляет собой подробно декодированные данные.

[000110] S204: получают первые данные из объекта данных, тип данных которого является типом данных в первом запросе подписки, и передают первые данные первой абонентской стороне.

[000111] Тип данных в запросе подписки представляет собой одно из исходного кодового потока, сводно декодированных данных и подробно декодированных данных, объект данных, тип данных которого представляет собой исходный кодовый поток, представляет собой оставшийся объект данных после удаления заголовка протокола, объект данных, тип данных которого является сводно декодированными данными, получают путем декодирования заголовка платформы сетевого элемента, заголовка идентификации продукта, заголовка информации услуги и других частей на основе объекта данных, тип данных которого является исходным кодовым потоком, и аналогично, объект данных, тип данных которого представляет собой подробно декодированные данные, получают путем декодирования тела данных на основе объекта данных, типом данных которого являются сводно декодированные данные.

[000112] Следовательно, сводно декодированные данные могут быть получены путем выполнения декодирования на основе исходного кодового потока, а подробно декодированные данные могут быть получены посредством дополнительного декодирования сводно декодированных данных. Если необходимо получить объект данных, типом данных которого являются сводно декодированные данные, необходимо сначала выполнить декодирование, чтобы получить объект данных, типом данных которого является исходный кодовый поток, и, если необходимо получить объект данных, типом данных которого являются подробно декодированные данные, необходимо выполнить декодирование, чтобы получить объект данных, типом данных которого являются сводно декодированные данные.

[000113] После удаления заголовка протокола из потока данных, полученного в соответствии с задачей сбора (например, совпадающей задачей сбора), чтобы получить объект данных, типом данных которого является исходный кодовый поток, полученный исходный кодовый поток может быть сохранен, и определяют, есть ли запрос подписки, который подписывается на часть данных или все данные, и в котором тип данных представляет собой сводно декодированные данные или подробно декодированные данные (например, определяют, является ли тип данных первого запроса подписки сводно декодированными данными или подробно декодированными данными). Если это так (т.е. тип данных в первом запросе подписки представляет собой сводно декодированные данные или подробно декодированные данные), объект данных, типом данных которого является исходный кодовый поток, дополнительно декодируют, чтобы получить объект данных, у которого соответствующим типом данных являются сводно декодированные данные, и объект данных сохраняют; и затем определяют, имеется ли запрос подписки, который подписывается на часть или на все данные и в котором типом данных являются подробно декодированные данные; и, если да, то объект данных, типом данных которого являются сводно декодированные данные, дополнительно декодируют, чтобы получить объект данных, соответствующим типом данных которого являются подробно декодированные данные, и объект данных сохраняют.Диспетчер сетевых элементов выбирает соответствующий объект данных из сохраненных объектов данных в соответствии с различными запросами подписки и передает соответствующий объект данных абонентской стороне.

[000114] Например, диспетчер сетевых элементов получает запрос 4 подписки в предыдущий момент, а необработанный запрос подписки включает только запрос 4 подписки, и запрос 4 подписки, в частности, выглядит следующим образом.

[000115] Задача 4 сбора, установленная в соответствии с запросом 4 подписки, выглядит следующим образом.

[000116] Первый запрос подписки выглядит следующим образом.

[000117] Путем сравнения списка данных подписки, типа сетевого элемента подписки, области подписки, объекта подписки, типа подписки, элемента подписки, параметра подписки и периода времени подписки установлено, что запрашиваемые данные, которые должны быть собраны первым запросом подписки, представляют собой часть данных, запрошенных для сбора с помощью запроса 4 подписки, которые ранее были приняты диспетчером сетевых элементов, так что соответствующая задача 4 сбора является совпадающей задачей сбора.

[000118] Тип данных, включенный в запрос 4 подписки, соответствующий совпадающей задаче сбора, представляет собой подробно декодированные данные, и, таким образом, после сбора соответствующего потока данных, то есть после того как собран поток данных контрольного теста и данных сканирования спектра беспроводного модуля с ID=1 45-го сетевого элемента eNodeB в течение периода времени с 10:00 до 10:30, заголовок протокола удаляют для получения соответствующего объекта данных и сохраняют объект данных в кэше данных.

[000119] Если в качестве кэша данных используется очередь сообщений Kafka, объект данных, полученный путем удаления заголовка протокола, может быть сохранен в топике 1 (topic) Kafka. Определяют, имеется ли запрос подписки, тип данных которого представляет собой сводно декодированные данные или подробно декодированные данные, из всех запросов подписки (запроса 4 подписки и первого запроса подписки), которые подписываются на какую-либо часть объекта данных.

[000120] Если это так (тип данных в запросе 4 подписки - это подробно декодированные данные, а тип данных в первом запросе подписки - это сводно декодированные данные), данные извлекают из топике 1 Kafka и передают на следующий вычислительный узел (например, узел BriefDecodeEvent), выполняют сводное декодирование данных в этом узле и определяют, имеется ли запрос подписки, типом данных которого являются сводно декодированные данные, из всех запросов подписки (т.е. запроса 4 подписки и первого запроса подписки), которые подписываются на какую-либо часть объекта данных.

[000121] Если имеется запрос подписки, тип данных которого представляет собой сводно декодированные данные, из всех запросов подписки (т.е. запроса 4 подписки и первого запроса подписки), которые подписываются на какую-либо часть объекта данных, объект данных, полученный этим узлом, сохраняют в топике 2 Kafka, и определяют, имеется ли запрос подписки, тип данных которого представляет собой подробно декодированные данные, из всех запросов подписки (т.е. запроса 4 подписки и первого запроса подписки), которые подписываются на какую-либо часть объекта данных; и, если это так, поток декодированных данных передают на следующий вычислительный узел (например, распределительный узел distributorBolt) для подробного декодирования, чтобы получить объект данных, тип данных которого представляет собой подробно декодированные данные, и полученный объект данных сохраняют в топике 3 Kafka.

[000122] Если нет запроса подписки, типом данных которого являются сводно декодированные данные, из всех запросов подписки (т.е. запроса 4 подписки и первого запроса подписки), которые подписываются на какую-либо часть объекта данных, данные, извлеченные из топика 1 Kafka, могут быть переданы непосредственно на следующий вычислительный узел (например, распределительный узел distributorBolt) для подробного декодирования, чтобы получить объект данных, тип данных которого представляет собой подробно декодированные данные, а полученный объект данных сохраняют в топике 3 Kafka.

[000123] Диспетчер сетевых элементов может извлекать данные из разных топиков Kafka в соответствии с разными запросами подписки и передавать данные соответствующей абонентской стороне; и абонентская сторона также может напрямую извлекать нужные данные из разных топиков Kafka.

[000124] Разумеется, поскольку в топике находятся все объекты данных (например, объект данных, соответствующий потоку данных, полученному в соответствии с совпадающей задачей сбора), типом данных которых является исходный кодовый поток, в то время как абонентской стороне может понадобиться только часть данных (т.е. данные, подписанные первым запросом подписки), может потребоваться фильтрация данных, и соответствующие данные передают соответствующей абонентской стороне. Например, объект данных, полученный после декодирования потока данных, полученного в соответствии с совпадающей задачей сбора, фильтруют, первые данные отфильтровывают и передают первой абонентской стороне.

[000125] В предшествующем уровне техники, если для разных модулей услуги требуются одни и те же данные, например, как модулю А услуги, так и модулю В услуги требуются данные D, поскольку данные, собранные сетевым элементом, имеют фиксированный формат, модуль А услуги и модуль В услуги должен соответственно декодировать данные D после того, как данные D, собранные сетевым элементом, соответственно передают модулю А услуги и модулю В услуги, что по существу эквивалентно выполнению двойного (повторного) декодирования данных D, и повторное декодирование одних и тех же данных приводит к трате вычислительных ресурсов.

[000126] Варианты осуществления настоящего изобретения избегают повторного декодирования одних и тех же данных, и, кроме того, исключают необходимость повторного декодирования данных исходного кодового потока, когда типом данных являются подробно декодированные данные, что позволяет избежать траты ресурсов, вызванной повторным декодированием.

[000127] В некоторых вариантах осуществления изобретения, после декодирования потока получают объект данных, включающий первые данные, получают первые данные из объекта данных и передают их первой абонентской стороне, при этом способ также включает: передачу объекта данных по меньшей мере одной абонентской стороне, отличной от первой абонентской стороны.

[000128] В варианте осуществления изобретения на первые данные также могут подписаться другие абонентские стороны, например, запрос подписки для создания совпадающей задачи сбора очевидно подписывается на данные, включающие первые данные, поэтому полученный объект данных также может быть передан абонентской стороне, которая создает запрос подписки совпадающей задачи сбора.

[000129] Кроме того, абонентские стороны, отличные от первой абонентской стороны, могут подписаться на данные, содержащие первые данные, но тип данных в их запросах подписки может не совпадать с типом данных в первом запросе подписки, в этом случае полученный поток данных должен быть соответствующим образом декодирован, должен быть получен объект данных, тип данных которого является типом данных в соответствующем запросе подписки, и полученный объект данных должен быть передан соответствующей абонентской стороне.

[000130] Если тип данных в запросе подписки для создания совпадающей задачи сбора совпадает с типом данных в первом запросе подписки, нет необходимости снова декодировать поток данных, полученный в соответствии с совпадающей задачей сбора. Требуется только однократное декодирование, и соответствующий объект данных передают соответствующей абонентской стороне, что позволяет избежать траты сетевых ресурсов, вызванной повторным декодированием.

[000131] Аналогичным образом, если тип данных в запросе подписки для создания пересекающейся задачи сбора совпадает с типом данных в первом запросе подписки, нет необходимости дважды декодировать поток данных, полученный в соответствии с пересекающейся задачей сбора, требуется только однократное декодирование, и соответствующий объект данных передают соответствующей абонентской стороне, что позволяет избежать траты сетевых ресурсов, вызванной повторным декодированием. Альтернативно, когда тип данных в запросе подписки, полученном в момент времени в будущем относительно текущего момента времени, совпадает с типом данных в первом запросе подписки, а данные подписки включают первые данные, нет необходимости выполнять повторное декодирование, и необходимо передать абонентской стороне только первые данные, что позволяет избежать траты сетевых ресурсов, вызванной повторным декодированием.

[000132] Во втором аспекте, как показано на фиг.4, варианты осуществления настоящего изобретения предлагают диспетчер сетевых элементов, содержащий модуль приема, первый модуль определения, первый модуль обработки и второй модуль обработки.

[000133] Модуль приема сконфигурирован для приема первого запроса подписки от первой абонентской стороны. Первый запрос подписки используется для подписки на первые данные, а первые данные представляют собой конкретные данные в пределах будущего первого периода времени.

[000134] Первый модуль определения сконфигурирован для определения, имеется ли в настоящее время совпадающая задача сбора. Данные, запрошенные для сбора с помощью совпадающей задачи сбора, включают по меньшей мере первые данные.

[000135] Первый модуль обработки сконфигурирован так, чтобы при наличии совпадающей задачи сбора получать поток данных в соответствии с совпадающей задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне.

[000136] Второй модуль обработки сконфигурирован так, чтобы при отсутствии совпадающей задачи сбора создавать первую задачу сбора в соответствии с первым запросом подписки, при этом первая задача сбора используется для запроса сбора первых данных, получать поток данных в соответствии по меньшей мере с первой задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне.

[000137] В некоторых вариантах осуществления изобретения диспетчер сетевых элементов также содержит: второй модуль определения, третий модуль обработки и четвертый модуль обработки.

[000138] Второй модуль определения сконфигурирован для определения, имеется ли в настоящее время пересекающаяся задача сбора. Первые данные включают пересекающиеся данные, которые относятся к данным, запрошенным для сбора пересекающейся задачей сбора, и отличающиеся данные, которые не принадлежат к данным, запрошенным для сбора пересекающейся задачей сбора.

[000139] Третий модуль обработки сконфигурирован так, чтобы при наличии пересекающейся задачи сбора создавать первую задачу сбора для запроса сбора отличающихся данных, получать поток данных в соответствии с пересекающейся задачей сбора и первой задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне.

[000140] Четвертый модуль обработки сконфигурирован так, чтобы, когда нет пересекающейся задачи сбора, создавать первую задачу сбора для запроса сбора первых данных, получать поток данных в соответствии с первой задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне.

[000141] В некоторых вариантах осуществления изобретения получение первых данных из потока данных и передача первых данных первой абонентской стороне включают: декодирование потока данных, получение объекта данных, включающего первые данные, получение первых данных из объекта данных и передачу первых данных первой абонентской стороне.

[000142] В некоторых вариантах осуществления изобретения первый запрос подписки содержит тип данных.

[000143] Декодирование потока данных и получение объекта данных, содержащего первые данные, включают: декодирование потока данных и получение объекта данных, тип данных которого является типом данных в первом запросе подписки, при этом объект данных включает первые данные.

[000144] С помощью диспетчера сетевых элементов согласно вариантам осуществления настоящего изобретения, когда принимается новый запрос подписки, посредством определения, совпадают ли данные, ранее указанные запросом подписки, с данными, указанными ранее принятым запросом подписки, можно уменьшить повторный сбор данных и тем самым избежать излишней траты сетевых ресурсов.

[000145] Специалистам в данной области техники должно быть понятно, что функциональные модули/блоки на всех или некоторых шагах, а также система или устройства, раскрытые выше, могут быть реализованы в виде программного обеспечения, аппаратно-программного обеспечения, аппаратного обеспечения и их соответствующих комбинаций.

[000146] В аппаратной реализации разделение между функциональными модулями/блоками, упомянутое в приведенном выше описании, не обязательно соответствует разделению физических компонентов; например, один физический компонент может иметь множество функций, или одна функция или шаг могут выполняться несколькими физическими компонентами совместно.

[000147] Некоторые физические компоненты или все физические компоненты могут быть реализованы в виде программного обеспечения, выполняемого процессором (например, центральным процессором (Central Processing Unit, CPU), цифровым процессором сигналов или микропроцессором), или реализованы в виде аппаратных средств, или реализованы в виде интегральной схемы, такой как специализированная интегральная схема. Такое программное обеспечение может распространяться на машиночитаемом носителе, который может включать компьютерный носитель данных (или носитель для хранения данных) и среду передачи данных (или временный носитель). Как хорошо известно специалистам в данной области техники, термин "компьютерный носитель данных" включает энергозависимые и энергонезависимые носители, а также съемные и несъемные носители, которые реализованы в любом способе или технологии хранения информации (например, машиночитаемых команд, структур данных, программных модулей или других данных). Компьютерный носитель данных включает, не ограничиваясь этим, оперативную память (Random Access Memory, RAM), такую как синхронная динамическая оперативная память (Synchronous Dynamic Random Access Memory, SDRAM) и память с удвоенной скоростью передачи данных (Double Data Rate, DDR), постоянная память (Read-Only Memory, ROM), электрически стираемая программируемая постоянная память (Electrically Erasable Programmable Read-Only Memory, EEPROM), флэш-память (FLASH) или другие дисковые запоминающие устройства; компакт-диск, предназначенный только для чтения (Compact Disk Read Only Memory, CD-ROM), универсальный цифровой диск (Digital Versatile Disk, DVD) или другое запоминающее устройство на оптических дисках; кассета с магнитной лентой, магнитная лента, накопитель на магнитных дисках или другие магнитные запоминающие устройства; и любые другие носители, которые могут использоваться для хранения необходимой информации и доступны компьютеру. Кроме того, специалистам в данной области техники хорошо известно, что среда для связи обычно содержит машиночитаемые команды, структуры данных, программные модули или другие данные в форме модулированных сигналов данных, таких как несущие или другие механизмы передачи, и может включать любой носитель для доставки информации.

[000148] В настоящем описании раскрыты примеры, и, хотя используются конкретные термины, они используются и должны толковаться только как общие иллюстративные значения и не предназначены для ограничения изобретения. Специалистам в данной области понятно, что, если прямо не указано иное, признаки, характеристики и/или элементы, описанные в сочетании с конкретными вариантами осуществления изобретения, могут использоваться отдельно или в сочетании с признаками, характеристиками и/или элементами, описанными в связи с другими вариантами осуществления изобретения. Соответственно, специалистам в данной области техники будет понятно, что могут быть сделаны изменения в различных формах и деталях в пределах сущности настоящего изобретения, изложенного в прилагаемой формуле изобретения.

Изобретение относится к области техники сетей связи. Технический результат заключается в обеспечении возможности сбора данных, исключая необходимость повторного декодирования данных исходного кодового потока. Способ включает прием, от первой абонентской стороны, первого запроса подписки, используемого для подписки на первые данные, причем первые данные представляют собой конкретные данные в пределах будущего первого периода времени, определение, имеется ли в настоящее время совпадающая задача сбора, причем данные, запрошенные для сбора совпадающей задачей сбора, включают по меньшей мере первые данные, если имеется совпадающая задача сбора, получение потока данных в соответствии с совпадающей задачей сбора, получение первых данных из потока данных и передачу первых данных первой абонентской стороне и, если нет совпадающей задачи сбора, создание первой задачи сбора в соответствии с первым запросом подписки, при этом первую задачу сбора используют для запроса сбора первых данных, получение потока данных в соответствии по меньшей мере с первой задачей сбора, получение первых данных из потока данных и передачу первых данных первой абонентской стороне. 2 н. и 8 з.п. ф-лы, 4 ил.

1. Способ сбора данных, применимый в диспетчере сетевых элементов и включающий:

прием, от первой абонентской стороны, первого запроса подписки, используемого для подписки на первые данные, причем первые данные представляют собой конкретные данные в будущем первом периоде времени;

определение, имеется ли в настоящее время совпадающая задача сбора, причем данные, запрошенные для сбора совпадающей задачей сбора, содержат по меньшей мере первые данные;

в случае, когда имеется совпадающая задача сбора, получение потока данных в соответствии с совпадающей задачей сбора, получение первых данных из потока данных и передачу первых данных первой абонентской стороне; и

в случае, когда нет совпадающей задачи сбора, создание первой задачи сбора в соответствии с первым запросом подписки, причем первую задачу сбора используют для запроса сбора первых данных, получение потока данных в соответствии по меньшей мере с первой задачей сбора, получение первых данных из потока данных и передачу первых данных первой абонентской стороне.

2. Способ по п. 1, в котором создание первой задачи сбора в соответствии с первым запросом подписки включает:

определение, имеется ли в настоящее время пересекающаяся задача сбора, причем первые данные содержат пересекающиеся данные, которые принадлежат к данным, запрошенным для сбора пересекающейся задачей сбора, и отличающиеся данные, которые не принадлежат к данным, запрошенным для сбора пересекающейся задачей сбора;

в случае, когда имеется пересекающаяся задача сбора, создание первой задачи сбора для запроса сбора отличающихся данных, получение потока данных в соответствии с пересекающейся задачей сбора и первой задачей сбора, получение первых данных из потока данных и передачу первых данных первой абонентской стороне; и

в случае, когда нет пересекающейся задачи сбора, создание первой задачи сбора для запроса сбора первых данных, получение потока данных в соответствии с первой задачей сбора, получение первых данных из потока данных и передачу первых данных первой абонентской стороне.

3. Способ по п. 1 или 2, в котором получение первых данных из потока данных и передача первых данных первой абонентской стороне включают:

декодирование потока данных, получение объекта данных, содержащего первые данные, получение первых данных из объекта данных и передачу первых данных первой абонентской стороне.

4. Способ по п. 3, в котором первый запрос подписки содержит тип данных, а декодирование потока данных и получение объекта данных, содержащего первые данные, включают:

декодирование потока данных и получение объекта данных, типом данных которого является тип данных в первом запросе подписки, причем объект данных содержит первые данные.

5. Способ по п. 4, в котором декодирование потока данных и получение объекта данных, типом данных которого является тип данных в первом запросе подписки, включают:

декодирование потока данных и получение объекта данных, типом данных которого является исходный кодовый поток;

декодирование объекта данных, типом данных которого является исходный кодовый поток, и получение объекта данных, типом данных которого являются сводно декодированные данные;

декодирование объекта данных, типом данных которого являются сводно декодированные данные, и получение объекта данных, типом данных которого являются подробно декодированные данные; и

получение первых данных из объекта данных, типом данных которого является тип данных в первом запросе подписки, и передачу первых данных первой абонентской стороне.

6. Способ по п. 3, также включающий:

после декодирования потока данных, получение объекта данных, содержащего первые данные, получение первых данных из объекта данных и передачу первых данных первой абонентской стороне,

передачу объекта данных по меньшей мере одной абонентской стороне, отличной от первой абонентской стороны.

7. Диспетчер сетевых элементов, содержащий:

модуль приема, сконфигурированный для приема первого запроса подписки от первой абонентской стороны, причем первый запрос подписки используется для подписки на первые данные, а первые данные представляют собой конкретные данные в пределах будущего первого периода времени;

первый модуль определения, сконфигурированный для определения, имеется ли в настоящее время совпадающая задача сбора, причем данные, запрошенные для сбора совпадающей задачей сбора, содержат по меньшей мере первые данные;

первый модуль обработки, сконфигурированный так, чтобы, когда имеется совпадающая задача сбора, получать поток данных в соответствии с совпадающей задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне; и

второй модуль обработки, сконфигурированный так, чтобы, когда нет совпадающей задачи сбора, создавать первую задачу сбора в соответствии с первым запросом подписки, при этом первая задача сбора используется для запроса сбора первых данных, получать поток данных в соответствии по меньшей мере с первой задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне.

8. Диспетчер сетевых элементов по п. 7, также содержащий:

второй модуль определения, сконфигурированный для определения, имеется ли в настоящее время пересекающаяся задача сбора, причем первые данные содержат пересекающиеся данные, которые принадлежат к данным, запрошенным для сбора пересекающейся задачей сбора, и отличающиеся данные, которые не принадлежат к данным, запрошенным для сбора пересекающейся задачей сбора;

третий модуль обработки, сконфигурированный так, чтобы, когда имеется пересекающаяся задача сбора, создавать первую задачу сбора для запроса сбора отличающихся данных, получать поток данных в соответствии с пересекающейся задачей сбора и первой задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне; и

четвертый модуль обработки, сконфигурированный так, чтобы, когда нет пересекающейся задачи сбора, создавать первую задачу сбора для запроса сбора первых данных, получать поток данных в соответствии с первой задачей сбора, получать первые данные из потока данных и передавать первые данные первой абонентской стороне.

9. Диспетчер сетевых элементов по п. 7 или 8, в котором получение первых данных из потока данных и передача первых данных первой абонентской стороне включают:

декодирование потока данных, получение объекта данных, содержащего первые данные, получение первых данных из объекта данных и передачу первых данных первой абонентской стороне.

10. Диспетчер сетевых элементов по п. 9, в котором первый запрос подписки содержит тип данных, а

декодирование потока данных и получение объекта данных, содержащего первые данные, включают:

декодирование потока данных и получение объекта данных, типом данных которого является тип данных в первом запросе подписки, причем объект данных содержит первые данные.