Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagexml
titleProcess Class agent_in_dmz.process_class.xml
collapsetrue
<?xml version="1.0" encoding="ISO-8859-1"?>
<process_class  max_processes="10" remote_scheduler="http://dmzhost:4445">
</process_class>
Code Block
languagexml
titleJob Chain remote_files_local_processing
collapsetrue
<?xml version="1.0" encoding="ISO-8859-1"?>
<job_chain file_watching_process_class="agent_in_dmz">
    <file_order_source  directory="/srv/files/1/in"/>
    <job_chain_node  state="start" job="job1" next_state="continue" error_state="error"/>
    <job_chain_node  state="continue" job="job2" next_state="success" error_state="error"/>
    <file_order_sink  state="success" move_to="/tmp/jobscheduler/file/success" remove="no"/>
    <file_order_sink  state="error" move_to="/tmp/jobscheduler/file/error" remove="no"/>
</job_chain>

Explanations

 

  • A process class is configured in a separate file, e.g. agent_in_dmz.process_class.xml, as stated with the above sample. The process class specifies the protocol, host and port that the Agent is operated for.
  • The job chain references the above process class with the file_watching_process_class attribute that causes the subsequent configuration for file order sources and file order sinks to be applied to the respective JobScheduler Agent.
  • The <file_order_source> is configured as explained for a JobScheduler Master.
  • Subsequent jobs are executed on the JobScheduler Master
  • The <file_order_sink> specifies incoming files to be moved to different directories on the JobScheduler Agent host depending on the execution result of the job chain.

...

Code Block
languagexml
titleJob Chain remote_files_remote_processing
collapsetrue
<?xml version="1.0" encoding="ISO-8859-1"?>
<job_chain process_class="agent_in_dmz">
    <file_order_source  directory="/srv/files/2/in"/>
    <job_chain_node  state="start" job="job1" next_state="continue" error_state="error"/>
    <job_chain_node  state="continue" job="job2" next_state="success" error_state="error"/>
    <file_order_sink  state="success" move_to="/tmp/jobscheduler/file/success" remove="no"/>
    <file_order_sink  state="error" move_to="/tmp/jobscheduler/file/error" remove="no"/>
</job_chain>

...

Code Block
languagexml
titleJob Chain remote_files_local_transfer
collapsetrue
<?xml version="1.0" encoding="ISO-8859-1"?>
<job_chain  file_watching_process_class="agent_in_dmz">
    <file_order_source  directory="/srv/files/3/in"/>
    <job_chain_node  state="transfer" job="jade" next_state="success" error_state="error"/>
    <job_chain_node  state="success"/>
    <file_order_sink  state="error" move_to="/tmp/jobscheduler/file/error" remove="no"/>
</job_chain>

...

Code Block
languagexml
titleFile Transfer Job
collapsetrue
<?xml version="1.0" encoding="ISO-8859-1"?>
<job  title="API Job for JobScheduler Advanced Data Exchange" order="yes" stop_on_error="no" name="jade">
    <description >
        <include  file="jobs/jadeJob.xml"/>
    </description>
    <params >
        <param  name="operation" value="move"/>
        <param  name="source_host" value="dmzhost"/>
        <param  name="source_protocol" value="sftp"/>
        <param  name="source_ssh_auth_method" value="password"/>
        <param  name="source_user" value="foo"/>
        <param  name="source_password" value="bar"/>
        <param  name="target_dir" value="c:\temp"/>
        <param  name="target_protocol" value="local"/>
        <param  name="file_path" value="%scheduler_file_path%"/>
    </params>
    <script  language="java" java_class="sos.scheduler.jade.JadeJob"/>
    <run_time />
</job>

...