從 Cloud Run 服務連線至 Redis 執行個體

您可以透過直接虛擬私有雲輸出，從 Cloud Run 連線至 Redis 執行個體。

設定

如果您已安裝 Google Cloud CLI 並建立 Redis 執行個體，可以略過這些步驟。

  1. 安裝 gcloud CLI 並初始化：

    gcloud init

  2. 按照快速入門指南中的說明建立 Redis 執行個體。請記下 Redis 執行個體的區域、IP 位址和通訊埠。

準備設定虛擬私有雲網路輸出

如要連線至 Redis 執行個體，Cloud Run 服務必須有權存取 Redis 執行個體的授權虛擬私有雲網路。

如要找出這個網路的名稱，請執行下列指令：

    gcloud redis instances describe INSTANCE_ID --region REGION --format "value(authorizedNetwork)"

記下網路名稱。

應用程式範例

本 HTTP 伺服器應用程式範例會從 Cloud Run 服務與 Redis 執行個體建立連線。

複製所選程式設計語言的存放區，然後前往包含範例程式碼的資料夾：

Go

git clone https://github.com/GoogleCloudPlatform/golang-samples
cd golang-samples/memorystore/redis

Node.js

git clone https://github.com/GoogleCloudPlatform/nodejs-docs-samples
cd nodejs-docs-samples/memorystore/redis

Python

git clone https://github.com/GoogleCloudPlatform/python-docs-samples
cd python-docs-samples/memorystore/redis

每次存取 / 端點時，這個範例應用程式都會遞增 Redis 計數器。

Go

這個應用程式會使用 github.com/gomodule/redigo/redis 用戶端。執行下列指令即可安裝：

go get github.com/gomodule/redigo/redis


// Command redis is a basic app that connects to a managed Redis instance.
package main

import (
	"fmt"
	"log"
	"net/http"
	"os"

	"github.com/gomodule/redigo/redis"
)

var redisPool *redis.Pool

func incrementHandler(w http.ResponseWriter, r *http.Request) {
	conn := redisPool.Get()
	defer conn.Close()

	counter, err := redis.Int(conn.Do("INCR", "visits"))
	if err != nil {
		http.Error(w, "Error incrementing visitor counter", http.StatusInternalServerError)
		return
	}
	fmt.Fprintf(w, "Visitor number: %d", counter)
}

func main() {
	redisHost := os.Getenv("REDISHOST")
	redisPort := os.Getenv("REDISPORT")
	redisAddr := fmt.Sprintf("%s:%s", redisHost, redisPort)

	const maxConnections = 10
	redisPool = &redis.Pool{
		MaxIdle: maxConnections,
		Dial:    func() (redis.Conn, error) { return redis.Dial("tcp", redisAddr) },
	}

	http.HandleFunc("/", incrementHandler)

	port := os.Getenv("PORT")
	if port == "" {
		port = "8080"
	}
	log.Printf("Listening on port %s", port)
	if err := http.ListenAndServe(":"+port, nil); err != nil {
		log.Fatal(err)
	}
}

Node.js

這個應用程式會使用 redis 模組。

{
  "name": "memorystore-redis",
  "description": "An example of using Memorystore(Redis) with Node.js",
  "version": "0.0.1",
  "private": true,
  "license": "Apache Version 2.0",
  "author": "Google Inc.",
  "engines": {
    "node": ">=16.0.0"
  },
  "dependencies": {
    "redis": "^4.0.0"
  }
}


'use strict';
const http = require('http');
const redis = require('redis');

const REDISHOST = process.env.REDISHOST || 'localhost';
const REDISPORT = process.env.REDISPORT || 6379;

const client = redis.createClient(REDISPORT, REDISHOST);
client.on('error', err => console.error('ERR:REDIS:', err));

// create a server
http
  .createServer((req, res) => {
    // increment the visit counter
    client.incr('visits', (err, reply) => {
      if (err) {
        console.log(err);
        res.status(500).send(err.message);
        return;
      }
      res.writeHead(200, {'Content-Type': 'text/plain'});
      res.end(`Visitor number: ${reply}\n`);
    });
  })
  .listen(8080);

Python

這個應用程式使用 Flask 提供網頁服務，並使用 redis-py 套件與 Redis 執行個體通訊。

Flask==3.0.3
gunicorn==23.0.0
redis==6.0.0
Werkzeug==3.0.3
 
import logging
import os

from flask import Flask
import redis

app = Flask(__name__)

redis_host = os.environ.get("REDISHOST", "localhost")
redis_port = int(os.environ.get("REDISPORT", 6379))
redis_client = redis.StrictRedis(host=redis_host, port=redis_port)


@app.route("/")
def index():
    value = redis_client.incr("counter", 1)
    return f"Visitor number: {value}"


@app.errorhandler(500)
def server_error(e):
    logging.exception("An error occurred during a request.")
    return (
        """
    An internal error occurred: <pre>{}</pre>
    See logs for full stacktrace.
    """.format(
            e
        ),
        500,
    )


if __name__ == "__main__":
    # This is used when running locally. Gunicorn is used to run the
    # application on Google App Engine and Cloud Run.
    # See entrypoint in app.yaml or Dockerfile.
    app.run(host="127.0.0.1", port=8080, debug=True)

將應用程式部署至 Cloud Run

如要部署應用程式，請按照下列步驟操作：

  1. 將 Dockerfile 複製到來源目錄：

    cp cloud_run_deployment/Dockerfile .

  2. 執行下列指令，使用 Cloud Build 建構容器映像檔：

    gcloud builds submit --tag gcr.io/PROJECT_ID/visit-count

  3. 執行下列指令，將容器部署至 Cloud Run：

        gcloud run deploy \
    --image gcr.io/PROJECT_ID/visit-count \
    --allow-unauthenticated \
    --region REGION \
    --network NETWORK \
    --subnet SUBNET \
    --set-env-vars REDISHOST=REDIS_IP,REDISPORT=REDIS_PORT

    其中：

    • PROJECT_ID 是專案 ID。 Google Cloud
    • REGION 是 Redis 執行個體所在的地區。
    • NETWORK 是 Redis 執行個體所附加的授權 VPC 網路名稱。
    • SUBNET 是子網路的名稱。子網路不得小於 /26。直接虛擬私有雲輸出支援 IPv4 範圍 RFC 1918、RFC 6598 和 E 類。
    • REDIS_IP 和 REDIS_PORT 是 Redis 執行個體的 IP 位址和通訊埠編號。

部署作業順利完成後，指令列會顯示 Cloud Run 服務的網址。在網路瀏覽器中前往這個網址 (或使用 curl 等工具)，每次造訪服務時，Redis 執行個體上的計數就會增加。