If you can't find the product or version you're looking for, visit support.ataccama.com/downloads

Task Execution and Monitoring Services

These services are located in the com.ataccama.nme.internal.engine.services.handlers.BatchControlServiceBundle service bundle. The services allow external applications to schedule load and export operations without having to interact with the workflow component and/or parse the pages at the web console.

<service class="com.ataccama.nme.internal.engine.services.handlers.BatchControlServiceBundle" />

We use a placeholder instance entity Example, a placeholder master entity Example, and a placeholder master view Mv to illustrate the functionality of services.

invokeLoadOperation

Invokes a load operation with the given parameters. The request consists of the operation name and an optional list of operation parameters.

Sample request

<invokeLoadOperation>
  <name>crm_in</name>   <!-- load operation name -->
  <parameters>          <!-- zero or more parameters -->
    <parameter name="fileSuffix" value="20110812"/>
  </parameters>
</invokeLoadOperation>

The service returns immediately, placing the operation into the task queue. The response consists of a single value, taskId, assigned to the task. The getTaskStatus service can be used to query the state of the task.

invokeMultiLoadOperation

Invokes a multi load operation with the given parameters. The request consists of list of operation names and an optional list of operation parameters.

Sample request

<invokeMultiLoadOperation>
  <operations>
    <operation>crm_full</operation>
    <operation>life_full</operation>
  </operations>
  <parameters>
    <parameter name="someParam" value="someValue" />
  </parameters>
</invokeMultiLoadOperation>

invokeExportOperation

Invokes an export operation with the given parameters. The semantics of the request and response is the same as in the case of invokeLoadOperation.

Sample request

<invokeExportOperation>
  <name>full</name>     <!-- export operation name -->
  <parameters>          <!-- zero or more parameters -->
    <parameter name="referenceTransactionId" value="6226117"/>
  </parameters>
</invokeExportOperation>

getTasks

Returns all tasks including their ID, technical name, and statuses. Sorted from latest to oldest.

Sample request

<getTasks>
    <offset>0</offset>  <!-- support for paging, default value is 0 -->
    <count>50</count>   <!-- how many tasks to return, default value is 50 -->
</getTasks>

Optional paging is available, where offset defines the page order and count defines the page size.

Get task response

<getTasksResponse>
  <tasks>
    <task>
      <id>2</id>
      <typeId>batchLoad.crm_delta</typeId>
      <status>FINISHED_OK</status>
    </task>
    <task>
      <id>1</id>
      <typeId>multiLoad.batchLoad.crm_initial+batchLoad.life_initial+batchLoad.invest_initial+batchLoad.hub_reference_data_full</typeId>
      <status>FINISHED_OK</status>
    </task>
    <!-- ... more ... -->
  </tasks>
</getTasksResponse>

getTaskStatus

Retrieves the status details for a given <taskId> as well as information about related event handlers.

Sample request

<getTaskStatus>
  <taskId>202</taskId>
</getTaskStatus>

If the task is not found, the response contains the status with value NOT_FOUND (other fields are empty). Otherwise, a structure containing the task ID, metadata, and status is returned.

The status can be one of the following:

WAITING - The task is waiting in the queue.
RUNNING - The task is currently in progress.
FINISHED_OK - The task is successfully completed.
FINISHED_FAILURE - The task was completed with a failure.
ABORTING - The task is in the process of being stopped but is not yet fully terminated. Occurs when high availability (HA) RW-RO mode is used.
ABORTED - The task was successfully stopped and is no longer running. Occurs when high availability (HA) RW-RO mode is used.
STOPPING - The task is in the process of being stopped but is not yet fully terminated.
STOPPED - The task was successfully stopped and is no longer running.
CANCELING - The task is being canceled by a user before it could be processed.
CANCELED - The task was canceled by a user before it could be processed.

Event handler states are:

RECEIVING - Receiving events during NME Committing.
READY - All events were received and are ready to be published.
PUBLISHING - Publishing events via publishers.
PUBLISHED - All events were published successfully.
CORRUPTED - Persisted events in the eventHandler storage are corrupted.
CRASHED_RECEIVING - EventHandler session crashed during receiving, event will be discarded.
CRASHED_PUBLISHING - EventHandler session crashed during publishing, can be restarted.

Get task status response

<getTaskStatusResponse>
      <id>202</id>
      <typeId>batchLoad.crm_full</typeId>
      <status>FINISHED_OK</status>
      <eventHandlerTasks>
        <task>
          <name>default</name>
          <id>204</id>
          <state>PUBLISHED</state>
        </task>
        <task>
          <name>History</name>
          <id>205</id>
          <state>PUBLISHED</state>
        </task>
        <task>
          <name>MdaSync</name>
          <id>206</id>
          <state>PUBLISHED</state>
        </task>
      </eventHandlerTasks>
</getTaskStatusResponse>

Was this page useful?