Nutanix AHV Chargeback Report with Kestra

id: nutanix-inventory-chargeback
namespace: company.team
description: |
  Produce a Nutanix AHV chargeback report. List the VMs, compute a cost per VM
  from their resources, append the result to a Google Sheet for finance, and
  post a summary to Slack.

triggers:
  - id: monthly_report
    type: io.kestra.plugin.core.trigger.Schedule
    description: Produce the chargeback report monthly. Adjust or disable as needed.
    cron: "0 6 1 * *"
    disabled: true

inputs:
  - id: spreadsheet_id
    type: STRING
    defaults: "1BxiMVs0XRA5nFMdKvBdBZjgmUUqptlbs74OgvE2upms"
    description: Google Sheet ID that accumulates the chargeback rows.
  - id: core_hour_rate
    type: FLOAT
    defaults: 0.05
    description: Cost per vCPU-core per reporting period.

tasks:
  - id: list_vms
    type: io.kestra.plugin.ee.nutanix.ahv.ListVms
    description: List all AHV VMs with their resource configuration.
    host: "{{ secret('NUTANIX_HOST') }}"
    token: "{{ secret('NUTANIX_TOKEN') }}"
    fetchType: FETCH

  - id: compute_chargeback
    type: io.kestra.plugin.scripts.python.Script
    description: Compute per-VM cost and write a CSV chargeback report.
    taskRunner:
      type: io.kestra.plugin.scripts.runner.docker.Docker
    containerImage: python:3.11-slim
    beforeCommands:
      - pip install kestra
    inputFiles:
      vms.json: "{{ outputs.list_vms.rows }}"
    script: |
      import csv
      import json
      from kestra import Kestra

      rate = float("{{ inputs.core_hour_rate }}")
      with open("vms.json") as f:
          vms = json.load(f)

      total = 0.0
      with open("chargeback.csv", "w", newline="") as out:
          writer = csv.writer(out)
          for vm in vms:
              name = vm.get("name", "unknown")
              cores = (vm.get("numSockets", 1) or 1) * (vm.get("numCoresPerSocket", 1) or 1)
              cost = round(cores * rate, 2)
              total += cost
              writer.writerow([name, cores, cost])

      Kestra.outputs({"vm_count": len(vms), "total_cost": round(total, 2)})
    outputFiles:
      - chargeback.csv

  - id: append_to_sheet
    type: io.kestra.plugin.googleworkspace.sheets.Load
    description: Append the chargeback rows to the finance spreadsheet.
    from: "{{ outputs.compute_chargeback.outputFiles['chargeback.csv'] }}"
    spreadsheetId: "{{ inputs.spreadsheet_id }}"
    range: Chargeback
    insertType: APPEND
    serviceAccount: "{{ secret('GCP_SERVICE_ACCOUNT') }}"

  - id: notify
    type: io.kestra.plugin.slack.notifications.SlackIncomingWebhook
    description: Post the chargeback summary to Slack.
    url: "{{ secret('SLACK_WEBHOOK_URL') }}"
    payload: |
      {
        "text": "Nutanix chargeback: {{ outputs.compute_chargeback.vars.vm_count }} VMs, total {{ outputs.compute_chargeback.vars.total_cost }} for the period."
      }

Finance teams running private cloud on Nutanix AHV need a recurring, defensible cost-allocation report, but the inventory lives in Prism Central while the chargeback ledger lives in a spreadsheet. This blueprint closes that gap. It pulls every AHV virtual machine with its resource configuration, computes a cost per VM from vCPU cores and a configurable rate, appends the rows to a Google Sheet that accumulates one period per run, and posts a summary to Slack so stakeholders see the numbers without opening a tool. It is a complete Nutanix inventory, showback, and chargeback pipeline you can run on day one.

How it works

list_vms (io.kestra.plugin.ee.nutanix.ahv.ListVms) queries Prism Central with fetchType: FETCH and returns all AHV VMs and their socket and core configuration as rows.
compute_chargeback (io.kestra.plugin.scripts.python.Script, run on a python:3.11-slim Docker task runner) reads those rows, multiplies numSockets by numCoresPerSocket per VM, applies the core_hour_rate input, writes a chargeback.csv, and emits vm_count and total_cost outputs.
append_to_sheet (io.kestra.plugin.googleworkspace.sheets.Load) loads the CSV into the Chargeback range with insertType: APPEND, so each run adds a fresh period to the finance ledger.
notify (io.kestra.plugin.slack.notifications.SlackIncomingWebhook) posts the VM count and period total to Slack.
A Schedule trigger (monthly_report) is wired for the 1st of each month at 06:00 and ships disabled, ready to enable.

What you get

A current Nutanix AHV VM inventory on every run.
A per-VM cost breakdown driven by a single, adjustable rate input.
A growing Google Sheet ledger that finance can pivot and audit.
A Slack summary with VM count and total cost per period.

Who it's for

Platform and virtualization teams running Nutanix AHV.
FinOps and finance owners who need showback or chargeback numbers.
Infrastructure engineers automating recurring cost reporting.

Why orchestrate this with Kestra

Prism Central can list VMs but cannot run them through a pricing model, write them to a finance spreadsheet, and notify a channel on a schedule. Kestra ties those steps into one declarative YAML flow with event and schedule triggers, automatic retries, and full execution lineage, so a failed Sheets write or Slack post is visible and replayable instead of silent. You get auditable runs, versioned logic, and a single place to evolve the cost model.

Prerequisites

A Nutanix Prism Central endpoint reachable from your Kestra workers.
A Google Sheet shared with the service account, and its spreadsheet ID.
A Slack incoming webhook.

Secrets

NUTANIX_HOST: Prism Central host.
NUTANIX_TOKEN: Prism Central bearer token.
GCP_SERVICE_ACCOUNT: service account key JSON with Google Sheets access.
SLACK_WEBHOOK_URL: Slack incoming webhook URL.

Quick start

Add the four secrets above to your Kestra namespace.
Share the target spreadsheet with the service account and pass its ID as spreadsheet_id.
Set core_hour_rate to your pricing (defaults to 0.05).
Run the flow, then enable the monthly_report trigger to schedule it.

How to extend

Enrich the cost model in compute_chargeback with memory and storage, not just cores.
Add per-cluster or per-project labels and split the spreadsheet ranges accordingly.
Swap or add a destination, for example a database or object storage, alongside the Google Sheet.
Change the Schedule cron to weekly or quarterly, or trigger the flow from an external event.

Nutanix AHV Inventory and Chargeback Report

How it works

What you get

Who it's for

Why orchestrate this with Kestra

Prerequisites

Secrets

Quick start

How to extend

Links

Tasks

Orchestrate with Kestra

Share this Blueprint

Create a Blueprint

New to Kestra?

Nutanix AHV Inventory and Chargeback Report

How it works

What you get

Who it's for

Why orchestrate this with Kestra

Prerequisites

Secrets

Quick start

How to extend

Links

Tasks

Orchestrate with Kestra

Share this Blueprint

Create a Blueprint

More Infrastructure Blueprints

Gate Artifactory Quotas and Retention Before Artifacts Vanish

Snapshot Pages to the Wayback Machine After Deploy

Event-Driven Jenkins Job with Slack Status Notification

Istio Service Mesh Control Plane xDS Push Error Sentinel

Jenkins Build-to-Deploy Approval Gate with Teams Notification

JMS Live Queue Message Latency Sentinel

New to Kestra?