КОНСТРУИРУЕМЫЙ ПОТОК ДАННЫХ ДЛЯ УЛУЧШЕННОЙ ОБРАБОТКИ СОБЫТИЙ

1. Реализуемый компьютером способ для улучшенной обработки событий, при этом способ содержит этапы, на которых:
- принимают запрос на улучшенную обработку событий, при этом запрос на улучшенную обработку событий содержит индикатор относительно входных данных из источника данных в базе данных; при этом входные данные из источника данных в базе данных не ассоциированы с временным элементом для входных данных,
- осуществляют доступ к входным данным в индикаторе относительно входных данных с использованием источника конструируемых потоков данных, при этом источник конструируемых потоков данных предоставляет доступ к совокупности моментальных снимков данных в базе данных из источника данных в базе данных во времени, при этом к входным данным осуществляется доступ с использованием конструируемого потока данных, который содержит временной элемент; и
- формируют вывод для запроса на улучшенную обработку событий на основе входных данных, доступ к которым осуществляется с использованием конструируемого потока данных.
2. Способ по п. 1, в котором временной элемент указывает время, когда событие, ассоциированное с входными данными, возникает и сохраняется в качестве части моментального снимка события в данных в базе данных.
3. Способ по п. 1, в котором конструируемый поток данных выступает в качестве прокси для данных в базе данных таким образом, что конструируемый поток данных предоставляет повторяющиеся вычисления с использованием данных в базе данных, которые изменяются во времени, при этом к конструируемому потоку данных осуществляется доступ в качестве функции от выбранного значения и выбранного времени.
4. Способ по п. 1, дополнительно содержащий этапы, на которых:
- коррелируют первый временной элемент конструируемого потока данных со вторым временным элементом потока данных; и
- формируют вывод для запроса на улучшенную обработку событий на основе входных данных конструируемого потока данных и входных данных потока данных.
5. Способ по п. 1, в котором вывод ассоциирован с временным элементом срока действия, который указывает время, когда вывод на основе конструируемого потока данных точно отражает данные в данных в базе данных.
6. Один или более компьютерных носителей хранения данных, имеющих осуществленные исполняемые компьютером инструкции, которые при выполнении посредством одного или более процессоров инструктируют одному или более процессоров осуществлять способ для улучшенной обработки событий, при этом способ содержит:
- идентификацию источника данных в базе данных;
- дискретизацию, по меньшей мере, части данных в базе данных из источника данных в базе данных для того, чтобы формировать один или более моментальных снимков данных в базе данных,
- формирование конструируемого потока данных на основе одного или более моментальных снимков данных в базе данных, при этом конструируемый поток данных ассоциирован с временным элементом; и
- предоставление доступа к конструируемому потоку данных на основе запроса на улучшенную обработку событий; при этом запрос на улучшенную обработку событий ассоциирован с индикатором относительно входных данных в базе данных источника данных в базе данных, доступного с использованием конструируемого потока данных, при этом входные данные из источника данных в базе данных не ассоциированы с временным элементом для входных данных.
7. Носители по п. 6, в которых дискретизация данных в базе данных основана, по меньшей мере, на одном из следующего:
(1) механизм периодической дискретизации, который формирует один или более моментальных снимков на основе предварительно определенного временного интервала;
(2) механизм дифференциальной дискретизации, который формирует один или более моментальных снимков, которые включают в себя только изменения данных в базе данных; и
(3) механизм уведомлений, который указывает то, когда возникает изменение данных в базе данных, так что моментальный снимок формируется при индикаторе относительно изменения данных в базе данных.
8. Носители по п. 7, в которых механизм уведомлений дополнительно содержит, по меньшей мере, одно из следующего:
(1) признак пакетной обработки, при этом признак пакетной обработки определяет предварительно определенное число изменений или определяет предварительно определенный период времени перед инициированием уведомления на то, чтобы выполнять дискретизацию; и
(2) административный временной элемент, который ассоциирован с рабочей функциональностью данных в базе данных, при этом административный временной элемент, не записывается в базе данных, при этом административный временной элемент указывает время, которое ассоциировано с моментальным снимком, который используется для того, чтобы формировать конструируемый поток данных с временным элементом.
9. Компьютерная система для выполнения улучшенной обработки событий, причем компьютерная система содержит:
- компонент управления источниками данных в базе данных, сконфигурированный с возможностью:
- предоставления доступа к данным в базе данных;
- компонент управления источниками конструируемых потоков данных, сконфигурированный с возможностью:
- идентификации источника данных в базе данных;
- дискретизации, по меньшей мере, части данных в базе данных из источника данных в базе данных для того, чтобы формировать один или более моментальных снимков данных в базе данных;
- формирования конструируемого потока данных на основе одного или более моментальных снимков данных в базе данных, при этом конструируемый поток данных ассоциирован с временным элементом; и
- предоставления доступа к конструируемому потоку данных на основе запроса на улучшенную обработку событий, при этом запрос на улучшенную обработку событий ассоциирован, по меньшей мере, с индикатором относительно входных данных в базе данных источника данных в базе данных, доступного с использованием конструируемого потока данных, при этом входные данные из источника данных в базе данных не ассоциированы с временным элементом для входных данных;
- источник потоков данных, сконфигурированный с возможностью:
- предоставления доступа к потоку данных;
- сервер улучшенной обработки событий, сконфигурированный с возможностью:
- приема запроса на улучшенную обработку событий, при этом запрос на улучшенную обработку событий содержит индикатор относительно входных данных из источника данных в базе данных и второй индикатор относительно входных данных из источника потоков данных;
- осуществления доступа к входным данным в индикаторе относительно входных данных с использованием источника конструируемых потоков данных, при этом источник конструируемых потоков данных предоставляет доступ к совокупности моментальных снимков данных в базе данных из источника данных в базе данных во времени, при этом к входным данным осуществляется доступ с использованием конструируемого потока данных, который содержит первый временной элемент;
- осуществления доступа к входным данным во втором индикаторе относительно входных данных с использованием источника потоков данных; и
- корреляции первого временного элемента конструируемого потока данных со вторым временным элементом потока данных; и
- формирования вывода для запроса на улучшенную обработку событий на основе входных данных конструируемого потока данных и входных данных потока данных.
10. Система по п. 9, в которой сервер улучшенной обработки событий содержит логический модуль, при этом логический модуль сконфигурирован с возможностью:
- идентификации логики для формирования вывода на основе запроса на улучшенную обработку событий, при этом логика выбирается, по меньшей мере, из одного из следующего:
- логика управления наиболее актуальными моментальными снимками; и
- логика интерполяции;
- предоставления логики, в которой такой вывод формируется на основе логики, при этом логика является обратно совместимой с конструируемым потоком данных.