Release Pipeline DR

The release_pipeline_dr.py script is an example of how to perform a DR failover for two atoms within a single Boomi Environment and with an active-active DR configuration. The script will turn off schedules and listeners in the atom that is down and turn on schedules and listeners on the other atom. When the down atom come back online, it will initially sync with the Boomi platform and the action to turn off schedules and listeners will occur then. The script will loop through the release file that is used within the release_pipeline script. That way, the same processes that are deployed during the initial release will failover.

import boomi_cicd


# This script is used to turn off listener and batch schedules in primary atom and on in DR
# The atoms are set up in an active-active configuration within the same environment
# No persisted properties are being used on the primary atom

# Open release json
releases = boomi_cicd.set_release()

# Get atom id
atom_id = boomi_cicd.query_atom(boomi_cicd.ATOM_NAME)
atom_dr_id = boomi_cicd.query_atom(boomi_cicd.ATOM_NAME_DR)

for release in releases["pipelines"]:
    component_id = release["componentId"]
    # Turn off listener in primary and on in DR
    if "listenerStatus" in release:
        boomi_cicd.change_listener_status(component_id, atom_id, "pause")
        boomi_cicd.change_listener_status(component_id, atom_id, "resume")

    # Pause schedules in primary and resume in DR
    if "schedule" in release:
        # Get conceptual id of deployed process
        conceptual_id = boomi_cicd.query_process_schedule_status(atom_id, component_id)
        conceptual_id_dr = boomi_cicd.query_process_schedule_status(
            atom_dr_id, component_id
        )

        boomi_cicd.update_process_schedule_status(
            component_id, conceptual_id, atom_id, False
        )
        boomi_cicd.update_process_schedule_status(
            component_id, conceptual_id_dr, atom_dr_id, True
        )

Required Environment Variables

Environment Variable	Description
BOOMI_ACCOUNT_ID	The Boomi account ID.
BOOMI_ATOM_NAME	The name of the Boomi Atom.
BOOMI_ATOM_NAME_DR	The name of the Boomi Atom.
BOOMI_BASE_URL	The base URL for the Boomi API. https://api.boomi.com/api/rest/v1
BOOMI_PASSWORD	The Boomi password. Atomsphere API Token is recommended
BOOMI_RELEASE_FILE	The name of the release JSON file to use.
BOOMI_USERNAME	The Boomi username. Atomsphere API Token is recommended

Command Line Arguments

• -r, –release_file: The release JSON file to use. If not specified, then the BOOMI_RELEASE_FILE environment variable will be used.

Release JSON File

{
  "pipelines": [
    {
      "processName": "An Example Batch Process",
      "packageVersion": "2.0",
      "componentId": "83d6013f-96f5-4a75-a97b-f4934b0ec2e8",
      "notes": "This is an example set of notes",
      "schedule": "0 0 1 * * * ; 30 0 2-7 * * *",
      "automatedTestId": "used within automated_testing.py"
    },
    {
      "processName": "An Example Listener Process",
      "packageVersion": "1.0",
      "componentId": "b24f310b-6a66-4e0d-97a3-26f1e812b79a",
      "notes": "This is an example set of notes",
      "listenerStatus": "RUNNING"
    },
    {
      "processName": "An Example Custom Library",
      "componentId": "7bd40730-6df3-4ba9-b4b2-ed9153dbca6d",
      "packageVersion": "1.0",
      "notes": "Initial deployment"
    }
  ]
}