diff --git a/compute/compute/ingredients/instances/bulk_insert.py b/compute/compute/ingredients/instances/bulk_insert.py
new file mode 100644
index 000000000000..d7cf578d41af
--- /dev/null
+++ b/compute/compute/ingredients/instances/bulk_insert.py
@@ -0,0 +1,90 @@
+#  Copyright 2022 Google LLC
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+# flake8: noqa
+from typing import Iterable, Optional
+import uuid
+
+from google.cloud import compute_v1
+
+
+# <INGREDIENT bulk_insert_instance>
+def bulk_insert_instance(project_id: str, zone: str, template: compute_v1.InstanceTemplate,
+                         count: int, name_pattern: str, min_count: Optional[int] = None,
+                         labels: Optional[dict] = None) -> Iterable[compute_v1.Instance]:
+    """
+    Create multiple VMs based on an Instance Template. The newly created instances will
+    be returned as a list and will share a label with key `bulk_batch` and a random
+    value.
+
+    If the bulk insert operation fails and the requested number of instances can't be created,
+    and more than min_count instances are created, then those instances can be found using
+    the `bulk_batch` label with value attached to the raised exception in bulk_batch_id
+    attribute. So, you can use the following filter: f"label.bulk_batch={err.bulk_batch_id}"
+    when listing instances in a zone to get the instances that were successfully created.
+
+    Args:
+        project_id: project ID or project number of the Cloud project you want to use.
+        zone: name of the zone to create the instance in. For example: "us-west3-b"
+        template: an Instance Template to be used for creation of the new VMs.
+        name_pattern: The string pattern used for the names of the VMs. The pattern
+            must contain one continuous sequence of placeholder hash characters (#)
+            with each character corresponding to one digit of the generated instance
+            name. Example: a name_pattern of inst-#### generates instance names such
+            as inst-0001 and inst-0002. If existing instances in the same project and
+            zone have names that match the name pattern then the generated instance
+            numbers start after the biggest existing number. For example, if there
+            exists an instance with name inst-0050, then instance names generated
+            using the pattern inst-#### begin with inst-0051. The name pattern
+            placeholder #...# can contain up to 18 characters.
+        count: The maximum number of instances to create.
+        min_count (optional): The minimum number of instances to create. If no min_count is
+            specified then count is used as the default value. If min_count instances
+            cannot be created, then no instances will be created and instances already
+            created will be deleted.
+        labels (optional): A dictionary with labels to be added to the new VMs.
+    """
+    bulk_insert_resource = compute_v1.BulkInsertInstanceResource()
+    bulk_insert_resource.source_instance_template = template.self_link
+    bulk_insert_resource.count = count
+    bulk_insert_resource.min_count = min_count or count
+    bulk_insert_resource.name_pattern = name_pattern
+
+    if not labels:
+        labels = {}
+
+    labels['bulk_batch'] = uuid.uuid4().hex
+    instance_prop = compute_v1.InstanceProperties()
+    instance_prop.labels = labels
+    bulk_insert_resource.instance_properties = instance_prop
+
+    bulk_insert_request = compute_v1.BulkInsertInstanceRequest()
+    bulk_insert_request.bulk_insert_instance_resource_resource = bulk_insert_resource
+    bulk_insert_request.project = project_id
+    bulk_insert_request.zone = zone
+
+    client = compute_v1.InstancesClient()
+    operation = client.bulk_insert(bulk_insert_request)
+
+    try:
+        wait_for_extended_operation(operation, "bulk instance creation")
+    except Exception as err:
+        err.bulk_batch_id = labels['bulk_batch']
+        raise err
+
+    list_req = compute_v1.ListInstancesRequest()
+    list_req.project = project_id
+    list_req.zone = zone
+    list_req.filter = " AND ".join(f"labels.{key}:{value}" for key, value in labels.items())
+    return client.list(list_req)
+# </INGREDIENT>
diff --git a/compute/compute/recipes/instances/bulk_insert.py b/compute/compute/recipes/instances/bulk_insert.py
new file mode 100644
index 000000000000..f5bfda9617ac
--- /dev/null
+++ b/compute/compute/recipes/instances/bulk_insert.py
@@ -0,0 +1,40 @@
+#  Copyright 2022 Google LLC
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+# flake8: noqa
+
+# <REGION compute_instances_bulk_insert>
+# <IMPORTS/>
+
+# <INGREDIENT wait_for_extended_operation />
+
+# <INGREDIENT get_instance_template />
+
+# <INGREDIENT bulk_insert_instance />
+
+
+def create_five_instances(project_id: str, zone: str, template_name: str,
+                          name_pattern: str):
+    """
+    Create five instances of an instance template.
+
+    Args:
+        project_id: project ID or project number of the Cloud project you want to use.
+        zone: name of the zone to create the instance in. For example: "us-west3-b"
+        template_name: name of the template that will be used to create new VMs.
+        name_pattern: The string pattern used for the names of the VMs.
+    """
+    template = get_instance_template(project_id, template_name)
+    instances = bulk_insert_instance(project_id, zone, template, 5, name_pattern)
+    return instances
+# </REGION compute_instances_bulk_insert>
diff --git a/compute/compute/snippets/instances/bulk_insert.py b/compute/compute/snippets/instances/bulk_insert.py
new file mode 100644
index 000000000000..efe095e3e1f1
--- /dev/null
+++ b/compute/compute/snippets/instances/bulk_insert.py
@@ -0,0 +1,191 @@
+#  Copyright 2022 Google LLC
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+# flake8: noqa
+
+
+# This file is automatically generated. Please do not modify it directly.
+# Find the relevant recipe file in the samples/recipes or samples/ingredients
+# directory and apply your changes there.
+
+
+# [START compute_instances_bulk_insert]
+import sys
+from typing import Any, Iterable, Optional
+import uuid
+
+from google.api_core.extended_operation import ExtendedOperation
+from google.cloud import compute_v1
+
+
+def wait_for_extended_operation(
+    operation: ExtendedOperation, verbose_name: str = "operation", timeout: int = 300
+) -> Any:
+    """
+    This method will wait for the extended (long-running) operation to
+    complete. If the operation is successful, it will return its result.
+    If the operation ends with an error, an exception will be raised.
+    If there were any warnings during the execution of the operation
+    they will be printed to sys.stderr.
+
+    Args:
+        operation: a long-running operation you want to wait on.
+        verbose_name: (optional) a more verbose name of the operation,
+            used only during error and warning reporting.
+        timeout: how long (in seconds) to wait for operation to finish.
+            If None, wait indefinitely.
+
+    Returns:
+        Whatever the operation.result() returns.
+
+    Raises:
+        This method will raise the exception received from `operation.exception()`
+        or RuntimeError if there is no exception set, but there is an `error_code`
+        set for the `operation`.
+
+        In case of an operation taking longer than `timeout` seconds to complete,
+        a `concurrent.futures.TimeoutError` will be raised.
+    """
+    result = operation.result(timeout=timeout)
+
+    if operation.error_code:
+        print(
+            f"Error during {verbose_name}: [Code: {operation.error_code}]: {operation.error_message}",
+            file=sys.stderr,
+            flush=True,
+        )
+        print(f"Operation ID: {operation.name}", file=sys.stderr, flush=True)
+        raise operation.exception() or RuntimeError(operation.error_message)
+
+    if operation.warnings:
+        print(f"Warnings during {verbose_name}:\n", file=sys.stderr, flush=True)
+        for warning in operation.warnings:
+            print(f" - {warning.code}: {warning.message}", file=sys.stderr, flush=True)
+
+    return result
+
+
+def get_instance_template(
+    project_id: str, template_name: str
+) -> compute_v1.InstanceTemplate:
+    """
+    Retrieve an instance template, which you can use to create virtual machine
+    (VM) instances and managed instance groups (MIGs).
+
+    Args:
+        project_id: project ID or project number of the Cloud project you use.
+        template_name: name of the template to retrieve.
+
+    Returns:
+        InstanceTemplate object that represents the retrieved template.
+    """
+    template_client = compute_v1.InstanceTemplatesClient()
+    return template_client.get(project=project_id, instance_template=template_name)
+
+
+def bulk_insert_instance(
+    project_id: str,
+    zone: str,
+    template: compute_v1.InstanceTemplate,
+    count: int,
+    name_pattern: str,
+    min_count: Optional[int] = None,
+    labels: Optional[dict] = None,
+) -> Iterable[compute_v1.Instance]:
+    """
+    Create multiple VMs based on an Instance Template. The newly created instances will
+    be returned as a list and will share a label with key `bulk_batch` and a random
+    value.
+
+    If the bulk insert operation fails and the requested number of instances can't be created,
+    and more than min_count instances are created, then those instances can be found using
+    the `bulk_batch` label with value attached to the raised exception in bulk_batch_id
+    attribute. So, you can use the following filter: f"label.bulk_batch={err.bulk_batch_id}"
+    when listing instances in a zone to get the instances that were successfully created.
+
+    Args:
+        project_id: project ID or project number of the Cloud project you want to use.
+        zone: name of the zone to create the instance in. For example: "us-west3-b"
+        template: an Instance Template to be used for creation of the new VMs.
+        name_pattern: The string pattern used for the names of the VMs. The pattern
+            must contain one continuous sequence of placeholder hash characters (#)
+            with each character corresponding to one digit of the generated instance
+            name. Example: a name_pattern of inst-#### generates instance names such
+            as inst-0001 and inst-0002. If existing instances in the same project and
+            zone have names that match the name pattern then the generated instance
+            numbers start after the biggest existing number. For example, if there
+            exists an instance with name inst-0050, then instance names generated
+            using the pattern inst-#### begin with inst-0051. The name pattern
+            placeholder #...# can contain up to 18 characters.
+        count: The maximum number of instances to create.
+        min_count (optional): The minimum number of instances to create. If no min_count is
+            specified then count is used as the default value. If min_count instances
+            cannot be created, then no instances will be created and instances already
+            created will be deleted.
+        labels (optional): A dictionary with labels to be added to the new VMs.
+    """
+    bulk_insert_resource = compute_v1.BulkInsertInstanceResource()
+    bulk_insert_resource.source_instance_template = template.self_link
+    bulk_insert_resource.count = count
+    bulk_insert_resource.min_count = min_count or count
+    bulk_insert_resource.name_pattern = name_pattern
+
+    if not labels:
+        labels = {}
+
+    labels["bulk_batch"] = uuid.uuid4().hex
+    instance_prop = compute_v1.InstanceProperties()
+    instance_prop.labels = labels
+    bulk_insert_resource.instance_properties = instance_prop
+
+    bulk_insert_request = compute_v1.BulkInsertInstanceRequest()
+    bulk_insert_request.bulk_insert_instance_resource_resource = bulk_insert_resource
+    bulk_insert_request.project = project_id
+    bulk_insert_request.zone = zone
+
+    client = compute_v1.InstancesClient()
+    operation = client.bulk_insert(bulk_insert_request)
+
+    try:
+        wait_for_extended_operation(operation, "bulk instance creation")
+    except Exception as err:
+        err.bulk_batch_id = labels["bulk_batch"]
+        raise err
+
+    list_req = compute_v1.ListInstancesRequest()
+    list_req.project = project_id
+    list_req.zone = zone
+    list_req.filter = " AND ".join(
+        f"labels.{key}:{value}" for key, value in labels.items()
+    )
+    return client.list(list_req)
+
+
+def create_five_instances(
+    project_id: str, zone: str, template_name: str, name_pattern: str
+):
+    """
+    Create five instances of an instance template.
+
+    Args:
+        project_id: project ID or project number of the Cloud project you want to use.
+        zone: name of the zone to create the instance in. For example: "us-west3-b"
+        template_name: name of the template that will be used to create new VMs.
+        name_pattern: The string pattern used for the names of the VMs.
+    """
+    template = get_instance_template(project_id, template_name)
+    instances = bulk_insert_instance(project_id, zone, template, 5, name_pattern)
+    return instances
+
+
+# [END compute_instances_bulk_insert]
diff --git a/compute/compute/snippets/tests/test_bulk.py b/compute/compute/snippets/tests/test_bulk.py
new file mode 100644
index 000000000000..2d270f1245a7
--- /dev/null
+++ b/compute/compute/snippets/tests/test_bulk.py
@@ -0,0 +1,76 @@
+#  Copyright 2022 Google LLC
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+import uuid
+
+import google.auth
+from google.cloud import compute_v1
+import pytest
+
+from ..instances.bulk_insert import create_five_instances
+from ..instances.delete import delete_instance
+
+PROJECT = google.auth.default()[1]
+INSTANCE_ZONE = "australia-southeast1-a"
+
+
+@pytest.fixture
+def instance_template():
+    disk = compute_v1.AttachedDisk()
+    initialize_params = compute_v1.AttachedDiskInitializeParams()
+    initialize_params.source_image = (
+        "projects/debian-cloud/global/images/family/debian-11"
+    )
+    initialize_params.disk_size_gb = 25
+    disk.initialize_params = initialize_params
+    disk.auto_delete = True
+    disk.boot = True
+
+    network_interface = compute_v1.NetworkInterface()
+    network_interface.name = "global/networks/default"
+
+    template = compute_v1.InstanceTemplate()
+    template.name = "test-template-" + uuid.uuid4().hex[:10]
+    template.properties.disks = [disk]
+    template.properties.machine_type = "n1-standard-4"
+    template.properties.network_interfaces = [network_interface]
+
+    template_client = compute_v1.InstanceTemplatesClient()
+    operation_client = compute_v1.GlobalOperationsClient()
+    op = template_client.insert_unary(
+        project=PROJECT, instance_template_resource=template
+    )
+    operation_client.wait(project=PROJECT, operation=op.name)
+
+    template = template_client.get(project=PROJECT, instance_template=template.name)
+
+    yield template
+
+    op = template_client.delete_unary(project=PROJECT, instance_template=template.name)
+    operation_client.wait(project=PROJECT, operation=op.name)
+
+
+def test_bulk_create(instance_template):
+    name_pattern = "i-##-" + uuid.uuid4().hex[:5]
+
+    instances = create_five_instances(PROJECT, INSTANCE_ZONE, instance_template.name,
+                                      name_pattern)
+
+    names = [instance.name for instance in instances]
+    try:
+        for i in range(1, 6):
+            name = name_pattern.replace('##', f"0{i}")
+            assert name in names
+    finally:
+        for name in names:
+            delete_instance(PROJECT, INSTANCE_ZONE, name)