如何仅在需要时运行 Google Cloud SQL？

Question

Google Cloud SQL 宣称，最小机器类型的每小时费用仅为 0.0150 美元，而且我要按每小时收费，而不仅仅是我连接的小时数。这是因为我正在使用游泳池吗？我如何设置我的后端，以便它仅在需要时查询云数据库，这样我就不会为一天中的每个小时收费？

const mysql      = require('mysql');
const pool = mysql.createPool({
    host : process.env.SQL_IP,
    user     : 'root',
    password : process.env.SQL_PASS,
    database : 'mydb',
    ssl      : {
          [redacted]
    }
});

function query(queryStatement, cB){
  pool.getConnection(function(err, connection) {
    // Use the connection
    connection.query(queryStatement, function (error, results, fields) {
      // And done with the connection.
      connection.destroy();
      // Callback
      cB(error,results,fields);

    });
  });
}

Answer 1

这与其说是关于池，还不如说是关于 Cloud SQL 的性质。与 App Engine 不同，Cloud SQL 实例始终处于启动状态。在我离开项目一周后的一个星期六早上，我艰难地了解到了这一点。:)

除非您明确停止服务，否则无法在不使用它们时停止它们。

无法安排服务停止，至少在 GCP SDK 中是这样。你总是可以编写一个 cron 作业，或者类似的东西gcloud sql instances patch [INSTANCE_NAME] --activation-policy NEVER，在例如当地时间下午 6 点，MF运行一个小命令。我懒得这样做，所以我只是为自己设置了一个日历提醒，在工作日结束时关闭我的实例。

这是当前 SDK 文档的 MySQL 实例启动/停止/重启页面：https : //cloud.google.com/sql/docs/mysql/start-stop-restart-instance

另外，根据流量，GCP 平台中有一个正在进行的“功能请求”以启动/停止 Cloud SQL（第 2 代）。您也可以访问该链接并在那里提供您宝贵的建议/意见。

Answer 2

我从@ingernet 那里得到了这个想法，并创建了一个云函数，该函数在需要时启动/停止 CloudSQL 实例。它可以通过计划作业触发，因此您可以定义实例何时启动或关闭。

详细信息在此Github Gist 中（灵感来自此处）。免责声明：我不是 Python 开发人员，因此代码中可能存在问题，但最终它可以工作。

基本上你需要遵循以下步骤：

1. 创建将用于触发云功能的发布/订阅主题。
2. 创建云函数并复制下面的代码。
   1. 确保在第 8 行设置正确的项目 ID。
   2. 将触发器设置为 Pub/Sub 并选择在步骤 1 中创建的主题。
3. 创建云调度器作业以定期触发云功能。
   1. 选择触发云功能的频率。
   2. 将目标设置为 Pub/Sub 并定义在步骤 1 中创建的主题。
   3. 负载应设置为start [CloudSQL instance name]或stop [CloudSQL instance name]以启动或停止指定的实例（例如，start my_cloudsql_instance将启动名称为 的 CloudSQL 实例my_cloudsql_instance）

主要.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)

需求.txt

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