A query controller accesses a cache comprising information related to data that is newly added to a database, responsive to detecting a data extraction application is ready to query the database for at least one data extraction rule. The information is added to the cache for each new data event received by a data processing application, prior to the data processing application adding the data parsed from each new data event to the database. The query controller evaluates each data extraction rule against the information in the cache to determine whether the information is relevant to at least one data extraction rule. The query controller sends a separate query by the data extraction application to the database only for any particular data extraction rules to which the information is relevant, such that the query controller reduces the number of queries sent for each query period to only queries based on data extraction rules that need to be reevaluated based on the information updated about data that is newly added to the database.