從 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)"

記下網路名稱。

範例函式

本範例函式會從 Cloud Run functions 建立與 Redis 執行個體的連線。

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

Go

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

Node.js

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

Python

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

範例程式碼會在每次觸發函式時遞增 Redis 計數器：

Go

這個函式會使用 github.com/gomodule/redigo/redis 用戶端。


// Package visitcount provides a Cloud Function that connects
// to a managed Redis instance.
package visitcount

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

	"github.com/GoogleCloudPlatform/functions-framework-go/functions"
	"github.com/gomodule/redigo/redis"
)

var redisPool *redis.Pool

func init() {
	// Register the HTTP handler with the Functions Framework
	functions.HTTP("VisitCount", visitCount)
}

// initializeRedis initializes and returns a connection pool
func initializeRedis() (*redis.Pool, error) {
	redisHost := os.Getenv("REDISHOST")
	if redisHost == "" {
		return nil, errors.New("REDISHOST must be set")
	}
	redisPort := os.Getenv("REDISPORT")
	if redisPort == "" {
		return nil, errors.New("REDISPORT must be set")
	}
	redisAddr := fmt.Sprintf("%s:%s", redisHost, redisPort)

	const maxConnections = 10
	return &redis.Pool{
		MaxIdle: maxConnections,
		Dial: func() (redis.Conn, error) {
			c, err := redis.Dial("tcp", redisAddr)
			if err != nil {
				return nil, fmt.Errorf("redis.Dial: %w", err)
			}
			return c, err
		},
	}, nil
}

// visitCount increments the visit count on the Redis instance
// and prints the current count in the HTTP response.
func visitCount(w http.ResponseWriter, r *http.Request) {
	// Initialize connection pool on first invocation
	if redisPool == nil {
		// Pre-declare err to avoid shadowing redisPool
		var err error
		redisPool, err = initializeRedis()
		if err != nil {
			log.Printf("initializeRedis: %v", err)
			http.Error(w, "Error initializing connection pool", http.StatusInternalServerError)
			return
		}
	}

	conn := redisPool.Get()
	defer conn.Close()

	counter, err := redis.Int(conn.Do("INCR", "visits"))
	if err != nil {
		log.Printf("redis.Int: %v", err)
		http.Error(w, "Error incrementing visit count", http.StatusInternalServerError)
		return
	}
	fmt.Fprintf(w, "Visit count: %d", counter)
}

Node.js

這個函式會使用 redis 模組。


const functions = require('@google-cloud/functions-framework');
const redis = require('redis');

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

const redisClient = redis.createClient({
  socket: {
    host: REDISHOST,
    port: REDISPORT,
  },
});
redisClient.on('error', err => console.error('ERR:REDIS:', err));
redisClient.connect();

functions.http('visitCount', async (req, res) => {
  try {
    const response = await redisClient.incr('visits');
    res.writeHead(200, {'Content-Type': 'text/plain'});
    res.end(`Visit count: ${response}`);
  } catch (err) {
    console.log(err);
    res.status(500).send(err.message);
  }
});

Python

這個函式會使用 redis-py 套件。


import os

import functions_framework
import redis

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)


@functions_framework.http
def visit_count(request):
    value = redis_client.incr("visits", 1)
    return f"Visit count: {value}"

將範例部署至 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。直接虛擬私有雲輸出支援 RFC 1918、RFC 6598 和 E 類 IPv4 範圍。
    • REDIS_IP 和 REDIS_PORT 是 Redis 執行個體的 IP 位址和通訊埠編號。

函式部署完成後，請擷取函式的網址：

gcloud run services describe visit-count \
--region=REGION

每次傳送 GET 要求至函式的網址，您都會看到計數器增加。