Using Resource Managers
The goal of this guide is to show you how to create a resource pool using the Python SDK, and how you can allocated resources with them.
The guide makes the assumption that we start with an Infrahub instance that doesn't have any data or schema loaded.
Loading a schema
Save the following schema in a file on your local system. The location or filename are not that important, but in this guide will be using /tmp/schema.yml
---
version: "1.0"
nodes:
- name: IPPrefix
namespace: Ipam
include_in_menu: false
inherit_from:
- "BuiltinIPPrefix"
description: "IPv4 or IPv6 network"
label: "IP Prefix"
- name: IPAddress
namespace: Ipam
include_in_menu: false
inherit_from:
- "BuiltinIPAddress"
description: "IP Address"
label: "IP Address"
- name: Device
namespace: Infra
description: "A Device"
icon: "mdi:server"
label: "Device"
attributes:
- name: name
kind: Text
label: Name
optional: false
relationships:
- name: primary_ip
label: "Primary IP Address"
peer: IpamIPAddress
optional: false
kind: Attribute
cardinality: one
Load the schema with the infrahubctl
command.
schema '/tmp/schema.yml' loaded successfully
1 schema processed in 6.846 seconds.
Creating an IP Prefix object
Next we will be creating an IP Prefix object, which the resource manager will use as a resource to allocate resources from.
- Async
- Sync
from infrahub_sdk import InfrahubClient
client = await InfrahubClientSync.init()
prefix = await client.create(kind="IpamIPPrefix", prefix="10.0.0.0/24", member_type="address")
await prefix.save()
from infrahub_sdk import InfrahubClientSync
client = InfrahubClientSync.init()
prefix = client.create(kind="IpamIPPrefix", prefix="10.0.0.0/24", member_type="address")
prefix.save()
Creating a resource manager
We can now create a resource manager of kind CoreIPAddressPool
. The kind of the resource manager determines the kind of resource the manager will allocate.
We will create a CoreIPaddressPool
with the following properties:
- Name: My IP address pool
- Default Address Type:
IpamIPAddress
(the kind of the IP address node defined in our schema) - Default Prefix Size: 32
- Resources: 10.0.0.0/24
- IP Namespace: Namespace > Default
- Async
- Sync
pool = await client.create(
kind="CoreIPAddressPool",
name="My IP address pool",
default_address_type="IpamIPAddress",
default_prefix_size=32,
resources=[prefix],
is_pool=True,
ip_namespace={"id": "default"}
)
await pool.save()
pool = client.create(
kind="CoreIPAddressPool",
name="My IP address pool",
default_address_type="IpamIPAddress",
default_prefix_size=32,
resources=[prefix],
is_pool=True,
ip_namespace={"id": "default"}
)
pool.save()
Allocating a resource out of the pool
We can now start allocating resources out of the CoreIPAddressPool
we created.
We can use the resource manager to allocate resources out of a pool in 2 different ways:
- Directly allocate a resource out of a pool. This is typically used when you need to allocate a resource that has no relation to other nodes. For example, allocating an IP address out of a pool that will be assigned to something that is not stored in Infrahub.
- Allocate a resource out of a pool to a relationship of a node. For example, create a device and allocate an IP address out of a pool and assign it to the device
Direct allocation of a resource
The Python SDK provides 2 methods that perform direct allocations:
allocate_next_ip_address
to allocate resources out ofCoreIPAddressPool
poolsallocate_next_ip_prefix
to allocated resources out ofCoreIPPrefixPool
pools
We will use allocate_next_ip_address
to allocated an IP address out of the CoreIPAddressPool
we created.
- Async
- Sync
ip_address = await client.allocate_next_ip_address(
resource_pool=pool,
data={"description": "my first allocated ip"}
)
ip_address = client.allocate_next_ip_address(
resource_pool=pool,
data={"description": "my first allocated ip"}
)
We provided a data argument to method. This data argument is used to pass attributes and relationships that we want to set on the allocated resource. In this case we are setting to the description of the allocated IP Address.
You can allocate resources in an idempotent way by passing an identifier argument to the allocation method. This identifier links the resource pool with the allocated resource allowing us to create idempotent allocation behavior. This is crucial when you want to allocate resources in an idempotent way using generators.
In this example we are executing the allocate_next_ip_address
method 2 times, using the same identifier.
- Async
- Sync
ip_address2 = await client.allocate_next_ip_address(resource_pool=pool, identifier="my-allocated-ip")
ip_address3 = await client.allocate_next_ip_address(resource_pool=pool, identifier="my-allocated-ip")
assert ip_address2.id == ip_address3.id
assert ip_address2.address.value == ip_address3.address.value
ip_address2 = client.allocate_next_ip_address(resource_pool=pool, identifier="my-allocated-ip")
ip_address3 = client.allocate_next_ip_address(resource_pool=pool, identifier="my-allocated-ip")
assert ip_address2.id == ip_address3.id
assert ip_address2.address.value == ip_address3.address.value
Allocating resources to a relationship of a node
Another way we can use resource managers is in situations where we create a node that has a relationship and we want to use a resource manager to allocate a new resource for that relationship. For example, we want to create a new device (or server) and assign an IP address to the device out of a pool.
The Python SDK allows you to set the relationship of a Node to the resource pool that you want to allocate from. The resource will be allocated when you save
the node.
- Async
- Sync
device = await client.create(kind="InfraDevice", name="dev-123", primary_ip=pool)
await device.save()
device = client.create(kind="InfraDevice", name="dev-123", primary_ip=pool)
device.save()
When you allocated to a relationship of a node, the resource allocation happens in an idempotent way. An identifier is automatically assigned to the resource allocation in this case.
Branch agnostic resource allocation
Resource managers have to allocate resources in a branch agnostic way. For example if we allocate a resource in a branch, then that resource should also be allocated in the main branch, even if the resource object does not yet exist in the main branch.
Without this behavior we could allocate the resource multiple times, which should not be possible.
Create a branch named test
- Async
- Sync
await client.branch.create("test")
client.branch.create("test")
Allocate a new IP address in the test
branch.
- Async
- Sync
ip_address4 = await client.allocate_next_ip_address(
resource_pool=pool,
branch="test"
)
ip_address4 = client.allocate_next_ip_address(
resource_pool=pool,
branch="test"
)
Currently there is no dedicated functionality in the Python SDK to do this, so for now we have to use a GraphQL query.
query {
InfrahubResourcePoolAllocated(pool_id: "<id of the pool>", resource_id: "<id of the prefix>") {
edges {
node {
display_label
branch
}
}
}
IpamIPAddress {
edges {
node {
display_label
}
}
}
}
Notice that we have one IP address allocated by the Resource manager in the test branch. The query in the main branch shows us this allocation, indicating that it has been allocated and the resource cannot be allocated again. However, the IP address does not exist itself within the main branch.