Historical data replay utilizing a computer system

1. A computer system for using a production environment to execute query programs in a simulated mode, the system comprising:

one or more processors;

computer readable storage coupled to the one or more processors, the computer readable storage having stored thereon instructions that, when executed by the one or more processors, cause the one or more processors to perform operations including:

establishing a digital connection between a query processor and a query client device;

receiving real-time data and storing historical data in the production environment, wherein the real-time data is continuously updated with current real-time data streams from a real-time data source, and wherein the historical data includes one or more of previously collected real-time data or other data not available in a real-time environment;

receiving at the query processor, a first query program with one or more first configuration instructions from the query client device;

the query processor determining from the one or more first configuration instructions from the query client device that a real-time mode is to be used when executing the first query program;

the query processor executing, in the real-time mode, the first query program in the production environment using production system code;

receiving at the query processor, a second query program with one or more second configuration instructions from the query client device;

the query processor parsing the one or more second configuration instructions;

the query processor determining from the one or more second configuration instructions from the query client device that a simulation mode is to be used when executing the second query program;

generating an update propagation graph (UPG) based on the second query program, the UPG having a plurality of nodes each corresponding to one of a plurality of data objects referenced by the dependencies between the plurality of data objects in the second query program;

applying simulated-real-time-data-historical filters to historical data;

converting the filtered historical data into simulated real-time data; and

using the simulated real-time data in a simulation including determining, for each clock cycle of one or more clock cycles of the simulation, data changes in the clock cycle and applying the data changes according to an order determined by the UPG.

2. The system of claim 1 , the operations further comprising:

requesting, by the one or more processors, non-action system generated historical data; and

creating, by the one or more processors, anti-look-ahead bias historical filters.

3. The system of claim 2 , the processing further comprising:

applying, by the query processor, the anti-look-ahead bias historical data filters to the requested non-action system generated real-time data simulated from historical data.

4. The system of claim 1 , the operations further comprising:

when a simulated real-time action system does not exist, constructing, by the one or more processors, a simulated real-time action system;

the query processor connecting to the simulated real-time action system; and

generating, by the one or more processor, simulated real-time action system data.

5. The system of claim 4 , the operations further comprising replacing the simulated real-time action system with a second simulated real-time action system.

6. The system of claim 1 ,

wherein the real-time data are simulated from historical data by reading a copy of underlying historical data and applying, after the reading, one or more changes to the read copy of underlying historical data; and

wherein the underlying historical data are unchanged by the reading and the applying.

7. The system of claim 1 , wherein the simulated real-time data-includes the query processor sorting the simulated real-time data prior to use by one or more of sequence ID or by time stamp.

8. The system of claim 1 , wherein the one or more first configuration instructions are different than the one or more second configuration instructions.

9. The system of claim 1 , wherein the first query program is different than the second query program.

10. A method for using a computer system in a production environment to execute query programs in a simulated mode, the method comprising:

establishing a digital connection between a query processor and a query client device;

the computer system receiving real-time data and storing historical data in the production environment, wherein the real-time data is collected at a rate depending on availability of the real-time data from a real-time data source;

receiving at the query processor, a first query program with one or more first configuration instructions from the query client device;

the query processor determining from the one or more first configuration instructions from the query client device that a real-time mode is to be used when executing the first query program;

the query processor executing, in the real-time mode, the first query program in the production environment using production system code;

receiving at the query processor, a second query program with one or more second configuration instructions from the query client device;

the query processor parsing the one or more second configuration instructions;

the query processor determining from the one or more second configuration instructions from the query client device that a simulation mode is to be used when executing the second query program;

requesting real-time data simulated from the historical data stored in the production environment, wherein changes to the real-time data simulated from the historical data made in preparation to use the altered data are made after the historical data is read from a data store, and wherein a simulated results log captures logged events from a simulation run;

generating an update propagation graph (UPG) based on the second query program, the UPG having a plurality of nodes each corresponding to one of a plurality of data objects referenced by the second query program, the UPG having a structure representing the dependencies between the plurality of data objects in the second query program; and

using the simulated real-time data in simulation including determining, for each clock cycle of one or more clock cycles of simulation, data changes in the clock cycle and applying the data changes according to an order determined by the UPG.

11. The method of claim 10 , further comprising:

requesting non-action system generated historical data; and

creating anti-look-ahead bias historical filters.

12. The method of claim 11 , further comprising:

applying the anti-look-ahead bias historical data filters to the requested non-action system generated real-time data simulated from historical data.

13. The method of claim 10 , further comprising:

when a simulated real-time action system does not exist, constructing a simulated real-time action system;

the query processor connecting to the simulated real-time action system; and

generating simulated real-time action system data.

14. The method of claim 10 , wherein real-time data simulated from historical data includes one or more of sorting the data by sequence ID or by time stamp.

15. The method of claim 14 , further comprising replacing the simulated real-time action system with a second simulated real-time action system.

16. The method of claim 10 ,

wherein the real-time data are simulated from historical data by reading a copy of underlying historical data and applying, after the reading, one or more changes to the read copy of underlying historical data; and

wherein the underlying historical data are unchanged by the reading and the applying.

17. The method of claim 10 , wherein the historical data includes data not available in a real-time environment.

18. The method of claim 10 , wherein the first query program is different than the second query program.

19. The method of claim 10 , wherein the one or more first configuration instructions are different than the one or more second configuration instructions.

20. A method for using a computer system in a production environment to execute query programs in a simulated mode, the method comprising:

establishing a digital connection between a query processor and a query client device;

the computer system receiving real-time data and storing historical data in the production environment, wherein the real-time data from a real-time data source;

receiving at the query processor, a first query program with one or more first configuration instructions from the query client device;

the query processor determining from the one or more first configuration instructions from the query client device that a real-time mode is to be used when executing the first query program;

the query processor executing, in the real-time mode, the first query program in the production environment using production system code;

receiving at the query processor, a second query problem with one or more second configuration instructions from the query client device;

the query processor parsing the one or more second configuration instructions;

the query processor determining from the one or more second configuration instructions from the query client device that a simulation mode is to be used when executing the second query program;

requesting real-time data simulated from the historical data stored in the production environment, wherein changes to the real-time data simulated from the historical data made in preparation to use the altered data are made after the historical data is read from a data store, and wherein a simulated results log captures logged events from a simulation run;

generating an update propagation graph (UPG) based on the second query program, the UPG having a plurality of nodes each corresponding to one of a plurality of data objects referenced by the second query program, the UPG having a structure representing the dependencies between the plurality of data objects in the second query program;

the query processor determining from the parsing of the one or more second configuration instructions a simulation clock cycle and a clock cycle speed; and

for each clock cycle:

starting a simulated clock cycle;

determining data changes in the clock cycle;

applying the data changes according to an order determined by the UPG; and

updating dynamic simulated real-time action system dynamic tables.

21. A method for using a computer system in a production environment to execute query programs in a simulated mode, the method comprising:

establishing a digital connection between a query processor and a query client device;

the computer system receiving real-time data and storing historical data in the production environment;

receiving at the query processor, a first query program with one or more first configuration instructions from the query client device;

the query processor determining from the one or more first configuration instructions from the query client device that a real-time mode is to be used when executing the first query program;

the query processor executing, in the real-time mode, the first query program in the production environment using production system code;

receiving at the query processor, a second query program with one or more second configuration instructions from the query client device;

the query processor parsing the one or more second configuration instructions;

the query processor determining from the one or more second configuration instructions from the query client device that a simulation mode is to be used when executing the second query program;

the query processor extracting a simulation period from the one or more second configuration instructions; and

performing simulation period operations including:

the query processor beginning a simulated clock cycle;

the query processor loading real-time data simulated from the historical data corresponding to the simulated clock cycle;

the query processor mapping dynamic real-time data objects in existence during the simulated clock cycle to the real-time simulated data;

the query processor processing changes to the dynamic real-time data objects through one or more update propagation graphs;

the query processor updating the dynamic real-time data objects based on the results from simulated actions; and

if a next simulated clock cycle is within the simulated period, repeating the above simulation period operations until the simulation period ends.

22. The method of claim 21 , further comprising:

the query processor determining a speed of the simulated clock cycle within the simulated period; and

the query processor passing results from simulated actions to simulated results and state logs.

23. The method of claim 21 , further comprising:

requesting non-action system generated historical data;

creating anti-look-ahead bias historical filters; and

applying the anti-look-ahead bias historical data filters to the requested non-action system generated real-time data simulated from historical data.

24. The method of claim 21 , further comprising:

when a simulated real-time action system does not exist, constructing a simulated real-time action system;

the query processor connecting to the simulated real-time action system;

generating simulated real-time action system data; and

replacing the simulated real-time action system with a second simulated real-time action system.

25. The method of claim 21 , wherein the historical data includes data not available in a real-time environment.

26. The method of claim 21 , wherein the real-time data simulated from historical data includes one or more of sorting the real-time simulated data by sequence ID or by time stamp for only the simulated clock cycle prior to use.