Leveraging advanced queues to implement event based job scheduling

• US 7,950,011 B2
• Filed: 10/10/2005
• Issued: 05/24/2011
• Est. Priority Date: 10/10/2005
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Ramkissoon, Ravi, Draaijer, Jacco, Mani, Raghu, Voss, Eric
• Primary Examiner(s): An; Meng-Ai
• Assistant Examiner(s): KUMABE, BLAKE K
• Application Number:
  US11/247,500
• Publication Number:
  US 20070083866A1
• Time in Patent Office: 2,052 Days
• Field of Search: 718/102
• US Class Current: 718/102
• CPC Class Codes: G06F 2209/544 Remote
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

A job scheduling technique that allows jobs to be launched as a result of messages which are not targeted specifically at the job, and for jobs to be interrelated in complex ways.

Claims

1. A method of job scheduling by a database system comprising:

creating a first job;

associating a scheduler agent to a queue comprising a queue message body;

creating a first rule associated with the scheduler agent, the first rule comprised of one or more conditions based at least in part upon a state change data in the queued message body;

registering the first job with the scheduler agent for notification of an event;

scheduling the event to trigger execution of the first job by using the first rule, the event being based at least in part upon the state change data in the queued message body, wherein the state change data is associated with the state change of a second job;

executing, by using a processor, the first job based at least in part upon the state change data; and

storing the state change data in a non-transitory computer-usable medium or displaying the state change data on a display device.

2. The method of claim 1, wherein the act of associating comprises subscribing the scheduler agent to the queue.

3. The method of claim 2, wherein the one or more conditions filter information from the queued message body.

4. The method of claim 2, wherein the queue is a database queue, the database queue storing messages from a database entity.

5. The method of claim 4, wherein the database entity is a module.

6. The method of claim 2, wherein the queue is a scheduler queue, the scheduler queue storing messages from one or more jobs.

7. The method of claim 2 wherein a first one and a second one of the one or more conditions are based at least in part upon a first message, and upon enqueuing of the first message, the first condition is true and triggers execution of a job and the second condition is false and does not trigger execution of a job.

8. The method of claim 1, wherein the message body includes job state, job owner, job name, event time stamp, event status, error message, run count, and failure count.

9. A computer program product embodied on a computer readable storage medium, the computer readable storage medium having stored thereon a sequence of instructions which, when executed by a processor, causes the processor to execute a method of job scheduling by a database system, the method comprising:

creating a first job;

associating a scheduler agent to a queue comprising a queue message body;

creating a first rule associated with the scheduler agent, the first rule comprised of one or more conditions based at least in part upon a state change data in the queued message body;

registering the first job with the scheduler agent for notification of an event;

scheduling the event to trigger execution of the first job by using the first rule, the event being based at least in part upon the state change data in the queued message body, wherein the state change data is associated with the state change of a second job;

executing the first job based at least in part upon the event; and

storing the state change data or displaying the state change data on a display device.

10. The computer program product of claim 9, wherein the act of associating comprises subscribing the scheduler agent to the queue.

11. The computer program product of claim 10, wherein the one or more conditions filter information from the queued message body.

12. The computer program product of claim 10, wherein the queue is a database queue, the database queue storing messages from a database entity.

13. The computer program product of claim 12, wherein the database entity is a module.

14. The computer program product of claim 10, wherein the queue is a scheduler queue, the scheduler queue storing messages from one or more jobs.

15. The computer program product of claim 10 wherein a first one and a second one of the one or more conditions are based at least in part upon a first message, and upon enqueuing of the first message, the first condition is true and triggers execution of a job and the second condition is false and does not trigger execution of a job.

16. The computer program product of claim 9, wherein the message body includes job state, job owner, job name, event time stamp, event status, error message, run count, and failure count.

17. A job scheduling system comprising:

one or more database queues created for purposes other than job scheduling comprising a first set of messages based at least in part upon events in the database environment;

a scheduler queue comprising a second set of messages based at least in part upon a state of one or more jobs in the database environment; and

a rules engine configured to create a plurality of rule sets based at least in part upon information contained in a message body of the first and second set of messages, wherein an event can be scheduled by a scheduling agent to trigger execution of a first job by using a first rule from the plurality of rule sets, the event being based at least in part upon the information contained in the second set of messages, the first job being registered with the scheduler agent for notification of the event, and the second set of messages is associated with the state of a second job.

18. The system of claim 17, wherein the rule sets comprise one or more conditions, the one or more conditions based at least in part upon the message body of the first and second set of messages and configured to trigger one of the one or more jobs to execute upon the condition being satisfied.

19. The system of claim 18, wherein the message body of the first and second set of messages comprises information regarding a job state of one of the one or more jobs.

20. The system of claim 18, wherein the conditions can be compound Boolean statements including multiple database events.

21. The system of claim 18, wherein a first condition based at least in part upon a first message body can evaluate to true and a second condition based at least in part upon the first message body can evaluate to false upon the enqueuing of the first message.

22. The system of claim 17 wherein the one or more database queues are unaware of a subscription.

23. The system of claim 17, wherein the rules are capable of utilizing all Boolean operators.