System and method for business process monitoring
Systems, methods, and computer-readable storage media for monitoring a pipeline of data without modifying code or otherwise impeding the pipeline. This is accomplished by identifying a class of software functions which modify other software function upon execution without modifying code for the other software functions, monitoring a pipeline of data to identify a plurality of jobs, the each job in the plurality of jobs comprising header information and body information, initiating, for each job in the plurality of jobs, a plurality of processes, modifying the plurality of processes based on the class, to yield advice modified processes, and outputting a status of the advice modified processes without modifying the pipeline.
1. A computer-implemented method comprising:
identifying, by a processor, a class of software functions which modify other software functions upon execution without modifying code for the other software functions;
monitoring, by the processor, data of a data pipeline to identify a plurality of jobs, each job of the plurality of jobs comprising header information and body information;
reading the data within the data pipeline at a first level of granularity, to yield granular data;
combining the granular data to form combined data;
identifying a job associated with the combined data, wherein the job is part of the plurality of jobs identified by the monitoring;
initiating, by the processor and for each job in the plurality of jobs, a plurality of processes;
modifying, by the processor and for each job in the plurality of jobs, the plurality of processes based on the class, to yield advice modified processes; and
outputting, by the processor and for each job in the plurality of jobs, a status of the corresponding advice modified processes without modifying the data of the data pipeline.
2. The method of claim 1 , the data pipeline comprising one of a wire or a fiber optic cable, wherein the status is output to a distinct channel than the data within the data pipeline.
3. The method of claim 1 , the data pipeline comprising one of a wire or a fiber optic cable, wherein the status is output to a distinct communication medium, the distinct communication medium comprising one of a distinct wire or a distinct fiber optic cable than the data pipeline.
4. The method of claim 1 , wherein the first level of granularity is a byte of data.
5. The method of claim 1 , further comprising:
combining the status with a plurality of status updates, to yield a combined status;
generating a context of the data pipeline based on the combined status; and
modifying a job in the plurality of jobs based on the context, to yield a modified job, the modified job requiring a change in processing power.
6. The method of claim 5 , wherein the change in processing power is a reduction in processing power required.
7. A system comprising:
a processor; and
a memory resource storing instructions, which, when executed by the processor, cause the processor to perform operations comprising:
identifying a class of software functions which modify other software functions upon execution without modifying code for the other software functions;
monitoring data of a data pipeline to identify a plurality of jobs, each job of the plurality of jobs comprising header information and body information;
reading the data within the data pipeline at a first level of granularity, to yield granular data;
combining the granular data to form combined data;
identifying a job associated with the combined data, wherein the job is part of the plurality of jobs identified by the monitoring;
initiating, for each job in the plurality of jobs, a plurality of processes;
modifying, for each job of the plurality of jobs, the plurality of processes based on the class, to yield advice modified processes; and
outputting, for each job of the plurality of jobs, a status of the corresponding advice modified processes without modifying the data of the data pipeline.
8. The system of claim 7 , the data pipeline comprising one of a wire or a fiber optic cable, wherein the status is output to a distinct channel than the data within the data pipeline.
9. The system of claim 7 , the data pipeline comprising one of a wire or a fiber optic cable, wherein the status is output to a distinct communication medium, the distinct communication medium comprising one of a distinct wire or a distinct fiber optic cable than the data pipeline.
10. The system of claim 7 , wherein the first level of granularity is a byte of data.
11. The system of claim 7 , the memory resource having additional instructions stored which, when executed by the processor, cause the processor to perform operations comprising:
combining the status with a plurality of status updates, to yield a combined status;
generating a context of the data pipeline based on the combined status; and
modifying a job in the plurality of jobs based on the context, to yield a modified job, the modified job requiring a change in processing power.
12. The system of claim 11 , wherein the change in processing power is a reduction in processing power required.
13. A non-transitory computer-readable storage medium having instructions stored which, when executed by a processor, cause the processor to perform operations comprising:
identifying a class of software functions which modify other software functions upon execution without modifying code for the other software functions;
monitoring data of a data pipeline to identify a plurality of jobs, each job of the plurality of jobs comprising header information and body information;
reading the data within the data pipeline at a first level of granularity, to yield granular data;
combining the granular data to form combined data;
identifying a job associated with the combined data, wherein the job is part of the plurality of jobs identified by the monitoring;
initiating, for each job in the plurality of jobs, a plurality of processes;
modifying, for each job of the plurality of jobs, the plurality of processes based on the class, to yield advice modified processes; and
outputting, for each job of the plurality of jobs, a status of the corresponding advice modified processes without modifying the data of the data pipeline.
14. The non-transitory computer-readable storage medium of claim 13 , the data pipeline comprising one of a wire or a fiber optic cable, wherein the status is output to a distinct channel than the data within the data pipeline.
15. The non-transitory computer-readable storage medium of claim 13 , the data pipeline comprising one of a wire or a fiber optic cable, wherein the status is output to a distinct communication medium, the distinct communication medium comprising one of a distinct wire or a distinct fiber optic cable than the data pipeline.
16. The non-transitory computer-readable storage medium of claim 13 , wherein the first level of granularity is a byte of data.
17. The non-transitory computer-readable storage medium of claim 13 , having additional instructions stored which, when executed by the processor, cause the processor to perform operations comprising:
combining the status with a plurality of status updates, to yield a combined status; generating a context of the data pipeline based on the combined status; and
modifying a job in the plurality of jobs based on the context, to yield a modified job, the modified job requiring a change in processing power.