Leveraging advanced queues to implement event based job scheduling

• US 20070083866A1
• Filed: 10/10/2005
• Published: 04/12/2007
• 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
• Granted Patent: US 7,950,011 B2
• Time in Patent Office: Days
• 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 comprising:

creating a first job;

scheduling an event to trigger execution of the first job, the event being based on data in a queued message body.

2. The method of claim 1, where scheduling an event, comprises:

subscribing a scheduler agent to a queue; and

creating a first rule associated with the scheduler agent, the first rule comprised of one or more conditions based on data in the queued message body which when true causes the execution of the first job; and

registering for notification of the event.

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 1, wherein scheduling an event comprises:

scheduling an event based on the state change of a second job, the state change of the second job being one of the plurality of data available in the queued message body.

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

9. The method of claim 2 wherein a first one and a second one of the one or more conditions are based on 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.

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

creating a first job;

scheduling an event to trigger execution of the first job, the event being based on data in a queued message body.

11. The computer program product of claim 10, where scheduling an event, comprises:

subscribing a scheduler agent to a queue; and

creating a first rule associated with the scheduler agent, the first rule comprised of one or more conditions based on data in the queued message body which when true causes the execution of the first job; and

registering for notification of the event.

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

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

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

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

16. The computer program product of claim 10, wherein scheduling an event comprises:

scheduling an event based on the state change of a second job, the state change of the second job being one of the plurality of data available in the queued message body.

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

18. The computer program product of claim 11 wherein a first one and a second one of the one or more conditions are based on 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.

19. A job scheduling system comprising:

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

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

a rules engine configured to create a plurality of rule sets based on information contained in a message body of the first and second set of messages.

20. The system of claim 19, wherein the rule sets comprise one or more conditions, each condition based on the message body and configured to trigger one of the one or more jobs to execute upon the condition being satisfied.

21. The system of claim 20, wherein the message body comprises information regarding a job state of one of the one or more jobs.

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

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

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

25. The system of claim 20, wherein a first condition based on a first message body can evaluate to true and a second condition based on the first message body can evaluate to false upon the enqueuing of the first message.