CODEWITHSUNDEEP
pythonpython-3.xgoogle-cloud-platform
Montana
Montana

Reputation: 47

Stop all instances in google cloud platform

I'm trying to write a script in python 3.8 in cloud functions to stop all of the instances (VM's) no matter about the region, instance name etc. Moreover I'm looking for Tag specified too. However I didn't found an answer anywhere, everywhere it's said I need to give project id, region and instance name. Is there any option to jump over it?

Upvotes: 0

Views: 756

Answers (1)

John Hanley
John Hanley

Reputation: 81336

Use the aggregatedList() and aggregatedList_next() methods to list all instances in all zones. Use the stop() method to terminate an instance. To understand the data returned by aggregatedList(), study the REST API response body.

from googleapiclient import discovery
from oauth2client.client import GoogleCredentials
credentials = GoogleCredentials.get_application_default()
service = discovery.build('compute', 'v1', credentials=credentials)

# Project ID for this request.
project = "REPLACE_ME"

request = service.instances().aggregatedList(project=project)
while request is not None:
    response = request.execute()
    instances = response.get('items', {})
    for instance in instances.values():
      for i in instance.get('instances', []):
          # Do something here to determine if this instance should be stopped.

          # Stop instance
          response = service.instances().stop(project=project, zone=zone, instance=i)

          # Add code to check the response, see below
    request = service.instances().aggregatedList_next(previous_request=request, previous_response=response)

Example code to check the response status returned by stop(). You might want to stop all instances and save each response in a list and then process the list until all instances have stopped.

while True:
    result = service.zoneOperations().get(
                project=project,
                zone=zone,
                operation=response['name']).execute()

    print('status:', result['status'])

    if result['status'] == 'DONE':
        print("done.")
        break;

    if 'error' in result:
        raise Exception(result['error'])

    time.sleep(1)

Upvotes: 2

Related Questions