Skip to content

Waldur Site Agent

Project for Waldur integration with a service provider's site. The main purpose of the agent is data syncronization between Waldur and a service backend (for example SLURM or MOAB cluster). The agent uses order information from Waldur to manage accounts in the site (backend) and accounting info from the site to update usage data in Waldur. For now, the agent supports only SLURM and MOAB clusters as a service backend.

Architecture

Agent is a stateless application, which is deployed on a machine with access to backend data. It consists of 4 sub-applications:

  • agent-order-process, which fetches ordering data from Waldur and updates a state of backend object correspondingly; (e.g. creates/updates/deletes SLURM accounts);
  • agent-report, which reports computing usage and limits info from the backend to Waldur (e.g. update of resource usages);
  • agent-membership-sync, which syncronizes membership info between Waldur and the backend (e.g. adds users to a SLURM allocation);
  • agent-event-process, which uses event-based approach to do the same as agent-order-process and agent-membership-sync; requires an MQTT-system as an event delivery queue between Waldur and the agent.

Integration with Waldur

The agent uses a Python-based Waldur client communicating with Waldur backend via REST interface. Agent-order-process application pulls data of orders created in Waldur and creates/updates/removes backend resources based on this info. Agent-report fetches usage data pushes it to Waldur. Agent-membership-sync fetches associations from a backend and syncronizes it with remote ones. Agent-event-process manages Waldur orders and membership in event-based way.

Integration with the site

SLURM cluster

The agent relies on SLURM command-line utilities (e.g. sacct and sacctmgr) and should run on a headnode of the SLURM cluster.

MOAB cluster

The agent relies on MOAB command line utilities (e.g. mam-list-accounts and mam-create-account) and should run on a headnode of the MOAB cluster as a root user.

Agent configuration

The application supports the following CLI arguments:

  • -m, --mode - mode of agent; supported values: order_process, report, membership_sync and event_process; default is order_process.
  • -c, --config-file - path to the config file with provider settings.

Optional environment variables:

  • WALDUR_SITE_AGENT_ORDER_PROCESS_PERIOD_MINUTES - trigger period for order_process mode in minutes (default is 5);
  • WALDUR_SITE_AGENT_REPORT_PERIOD_MINUTES - trigger period for report mode in minutes (default is 30);
  • WALDUR_SITE_AGENT_MEMBERSHIP_SYNC_PERIOD_MINUTES - trigger period for membership_sync mode in minutes (default is 5).
  • REQUESTS_VERIFY_SSL - flag for SSL verification for Waldur client, default is true.
  • SENTRY_ENVIRONMENT - name of the Sentry environment.

The main config source for the agent is waldur-site-agent-config.yaml file. Using it, the agent can serve multiple offerings and setup backend-related data, for example settings of computing components. File example and reference.

NB: for MOAB, the only acceptable backend component is deposit. All other specified components are ignored by the agent.

Deployment

A user can deploy 4 separate instances of the agent. The first one (called agent-order-process) fetches data from Waldur with further processing, the second one (called agent-report) sends usage data from the backend to Waldur the third one syncs membership information between Waldur and the backend and the optional fourth one processes order and membership info in event-based way. All the instances must be configured with provider config file and CLI variables.

To deploy them, you need to setup and start the systemd services.

Prerequisite: offering configuration in Waldur

SLURM and MOAB

Agents require a pre-created offering in Waldur. As a service provider owner, you should create a new offering in the marketplace:

  • Go to Service Provider section of the organization and open offering creation menu
  • Input a name, choose a category, select SLURM remote allocation from the drop-down list on the bottom and click Create button

offering-creation

  • Open the offering page, choose Edit tab, click Accounting section, choose Accounting plans from the drop-down list and create a plan: click Add plan and input the necessary details;

offering-plan

  • In the same page, click Integration section choose User management from the drop-down list and set the Service provider can create offering user option to Yes;

offering-user-management

  • Activate the offering using the big green button Activate.

Note: You will need to set the offering UUID in the agent config file. For this, you can copy the UUID from the Integration -> Credentials section on the same page:

offering-uuid

Setup

Firstly, install the waldur-site-agent module:

1
pip install waldur-site-agent

Secondly, create the provider config file and adjust the content for your needs.

1
cp examples/waldur-site-agent-config.yaml.example /etc/waldur/waldur-site-agent-config.yaml

Please use the waldur_site_load_components command to load computing components into Waldur. This step is necessary for correct setup of the offering in Waldur.

1
waldur_site_load_components -c /etc/waldur/waldur-site-agent-config.yaml

Thirdly, put systemd unit and provider config files to the corresponding locations.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
# For agent-order-process
cp systemd-conf/agent-order-process/agent.service /etc/systemd/system/waldur-agent-order-process.service

# For agent-report
cp systemd-conf/agent-report/agent.service /etc/systemd/system/waldur-agent-report.service

# For agent-membership-sync
cp systemd-conf/agent-membership-sync/agent.service /etc/systemd/system/waldur-agent-membership-sync.service

# For agent-event-process
cp systemd-conf/agent-event-process/agent.service /etc/systemd/system/waldur-agent-event-process.service

After these preparation steps, run the following script to apply the changes.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
systemctl daemon-reload

systemctl start waldur-agent-order-process.service
systemctl enable waldur-agent-order-process.service # to start after reboot

systemctl start waldur-agent-report.service
systemctl enable waldur-agent-report.service

systemctl start waldur-agent-membership-sync.service
systemctl enable waldur-agent-membership-sync.service

systemctl start waldur-agent-event-process.service
systemctl enable waldur-agent-event-process.service # to start after reboot

Event-based processing

Each offering from the config file can have mqtt_enabled set to true or false (false by default).

If this setting set to true, the offering is ignored by agent-order-process and agent-membership-sync, instead, the agent-event-process takes care of it.

Older systemd versions

If you want to deploy the agents on a machine with systemd revision older than 240, you should use files with legacy configuration:

1
2
3
4
5
6
7
8
# For agent-order-process
cp systemd-conf/agent-order-process/agent-legacy.service /etc/systemd/system/waldur-agent-order-process-legacy.service
# For agent-report
cp systemd-conf/agent-report/agent-legacy.service /etc/systemd/system/waldur-agent-report-legacy.service
# For agent-membership-sync
cp systemd-conf/agent-membership-sync/agent-legacy.service /etc/systemd/system/waldur-agent-membership-sync-legacy.service
# For agent-event-process
cp systemd-conf/agent-event-process/agent-legacy.service /etc/systemd/system/waldur-agent-event-process-legacy.service

Provider config file reference

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
sentry_dsn: "" # Data Source Name for Sentry (more info https://docs.sentry.io/product/sentry-basics/dsn-explainer/).
offerings: # Settings for offerings
  - name: "Example SLURM Offering" # offering name
    waldur_api_url: "http://localhost:8081/api/" # URL of Waldur API (e.g. http://localhost:8081/api/).
    waldur_api_token: "" # Token to access the Waldur API.
    waldur_offering_uuid: "" # UUID of the offering in Waldur.
    mqtt_enabled: true # MQTT feature toggler
    websocket_use_tls: true # Whether to use TLS for websocket connection
    backend_type: "slurm" # type of backend, for now only `slurm` and `moab` is supported
    backend_settings: # backend-specific settings
      default_account: "root" # Default parent account name in SLURM cluster
        # for new ones
      customer_prefix: "hpc_" # Prefix for customer's accounts.
      project_prefix: "hpc_" # Prefix for project's accounts.
      allocation_prefix: "hpc_" # Prefix used for allocation's accounts.
        # created by the agent.
      qos_downscaled: "limited" # The QoS set to an account after downscaling
      qos_paused: "paused" # The QoS set to an account after pausing
      qos_default: "normal" # The default QoS for account in the SLURM cluster
      enable_user_homedir_account_creation: true # Whether to create home directories
        # for users associated to accounts.
      homedir_umask: "0700" # A umask for created homedirs
    backend_components: # Computing components on backend with accounting data
      cpu: # Type of the component, for example `cpu`
        measured_unit: "k-Hours" # Waldur measured unit for accounting.
          # For example `k-Hours` for CPU
        unit_factor: 60000 # Factor for conversion from measured unit
          # to backend ones.
          # For example 60000 (60 * 1000) for CPU in SLURM,
          # which uses cpu-minutes for accounting
        accounting_type: "usage" # Can be either `usage` or `limit`
        label: "CPU" # A label for the component in Waldur
      mem:
        limit: 10 # Amount of measured units for Waldur (SLURM measured unit is MB-minutes)
        measured_unit: 'gb-Hours' # Waldur measured unit for accounting
        unit_factor: 61440 # Unit factor for conversion from measured unit
          # to SLURM units (60 * 1024)
        accounting_type: usage # Can be usage or limit
        label: RAM # A label for a component in Waldur
  - name: "Example MOAB Offering"
    waldur_api_url: "http://localhost:8081/api/"
    waldur_api_token: ""
    waldur_offering_uuid: ""
    backend_type: "moab"
    backend_settings:
      default_account: root
      customer_prefix: "c_"
      project_prefix: "p_"
      allocation_prefix: "a_"
      enable_user_homedir_account_creation: true
    backend_components:
      deposit: # For MOAB backend, only "deposit" is supported
        measured_unit: 'EUR'
        accounting_type: limit
        label: Deposit (EUR)