lovromazgon/README.md

## README.md

      
    Raw
  

              README.md
            
          
    To use this cloud function follow these steps:

Create a pub/sub topic which will be used to trigger the cloud function.
Create the cloud function and copy in the code below.

Make sure to set the correct project ID in line 8.
Set the trigger to Pub/Sub and choose the topic created in step 1.


Create a cloud scheduler job to trigger the cloud function on a regular basis.

Choose the frequency when you want the cloud function to be triggered.
Set the target to Pub/Sub and define the topic created in step 1.
The payload should be set to start [CloudSQL instance name] or stop [CloudSQL instance name] to start or stop the specified instance (e.g. start my_cloudsql_instance will start the CloudSQL instance with the name my_cloudsql_instance)


The code is based on this code so credit goes to chris32g.

  
## main.py
from googleapiclient import discovery
from oauth2client.client import GoogleCredentials
import base64
from pprint import pprint

credentials = GoogleCredentials.get_application_default()
service = discovery.build('sqladmin', 'v1beta4', credentials=credentials, cache_discovery=False)
project = 'INSERT PROJECT_ID HERE'

def start_stop(event, context):
  print(event)
  pubsub_message = base64.b64decode(event['data']).decode('utf-8')
  print(pubsub_message)
  command, instance_name = pubsub_message.split(' ', 1)

  if command == 'start':
    start(instance_name)
  elif command == 'stop':
    stop(instance_name)
  else:
    print("unknown command " + command)

def start(instance_name):
  print("starting " + instance_name)
  patch(instance_name, "ALWAYS")

def stop(instance_name):
  print("stopping " + instance_name)
  patch(instance_name, "NEVER")

def patch(instance, activation_policy):
  request = service.instances().get(project=project, instance=instance)
  response = request.execute()

  dbinstancebody = {
    "settings": {
      "settingsVersion": response["settings"]["settingsVersion"],
      "activationPolicy": activation_policy
    }
  }

  request = service.instances().patch(
    project=project,
    instance=instance,
    body=dbinstancebody)
  response = request.execute()
  pprint(response)

## requirements.txt
# Function dependencies, for example:
# package>=version

google-api-python-client==1.10.0
google-auth-httplib2==0.0.4
google-auth==1.19.2
oauth2client==4.1.3
	from googleapiclient import discovery
	from oauth2client.client import GoogleCredentials
	import base64
	from pprint import pprint

	credentials = GoogleCredentials.get_application_default()
	service = discovery.build('sqladmin', 'v1beta4', credentials=credentials, cache_discovery=False)
	project = 'INSERT PROJECT_ID HERE'

	def start_stop(event, context):
	print(event)
	pubsub_message = base64.b64decode(event['data']).decode('utf-8')
	print(pubsub_message)
	command, instance_name = pubsub_message.split(' ', 1)

	if command == 'start':
	start(instance_name)
	elif command == 'stop':
	stop(instance_name)
	else:
	print("unknown command " + command)

	def start(instance_name):
	print("starting " + instance_name)
	patch(instance_name, "ALWAYS")

	def stop(instance_name):
	print("stopping " + instance_name)
	patch(instance_name, "NEVER")

	def patch(instance, activation_policy):
	request = service.instances().get(project=project, instance=instance)
	response = request.execute()

	dbinstancebody = {
	"settings": {
	"settingsVersion": response["settings"]["settingsVersion"],
	"activationPolicy": activation_policy
	}
	}

	request = service.instances().patch(
	project=project,
	instance=instance,
	body=dbinstancebody)
	response = request.execute()
	pprint(response)
	# Function dependencies, for example:
	# package>=version

	google-api-python-client==1.10.0
	google-auth-httplib2==0.0.4
	google-auth==1.19.2
	oauth2client==4.1.3