Memorystore for Redis
透過集合功能整理內容
你可以依據偏好儲存及分類內容。
示範如何連線至受管理 Redis 執行個體的 Cloud Function。
深入探索
如需包含這個程式碼範例的詳細說明文件,請參閱下列內容:
程式碼範例
Node.js
如要驗證 Cloud Run 函式,請設定應用程式預設憑證。
詳情請參閱「為本機開發環境設定驗證」。
Python
如要驗證 Cloud Run 函式,請設定應用程式預設憑證。
詳情請參閱「為本機開發環境設定驗證」。
除非另有註明,否則本頁面中的內容是採用創用 CC 姓名標示 4.0 授權,程式碼範例則為阿帕契 2.0 授權。詳情請參閱《Google Developers 網站政策》。Java 是 Oracle 和/或其關聯企業的註冊商標。
[[["容易理解","easyToUnderstand","thumb-up"],["確實解決了我的問題","solvedMyProblem","thumb-up"],["其他","otherUp","thumb-up"]],[["難以理解","hardToUnderstand","thumb-down"],["資訊或程式碼範例有誤","incorrectInformationOrSampleCode","thumb-down"],["缺少我需要的資訊/範例","missingTheInformationSamplesINeed","thumb-down"],["翻譯問題","translationIssue","thumb-down"],["其他","otherDown","thumb-down"]],[],[[["\u003cp\u003eThis content showcases how to implement a Cloud Function that connects to a managed Redis instance for tracking visit counts.\u003c/p\u003e\n"],["\u003cp\u003eThe code samples demonstrate implementations in Go, Node.js, and Python, each connecting to Redis and incrementing a visit counter.\u003c/p\u003e\n"],["\u003cp\u003eThe Cloud Function code samples are provided, including error handling and connection pooling in the Go example and a direct connection in both Node.js and Python.\u003c/p\u003e\n"],["\u003cp\u003eSetting up Application Default Credentials (ADC) is necessary to authenticate to Cloud Run functions, and detailed instructions on how to set up ADC for local development environments are linked in the content.\u003c/p\u003e\n"]]],[],null,["# Memorystore for Redis\n\nDemonstrates a Cloud Function that connects to a managed Redis instance.\n\nExplore further\n---------------\n\n\nFor detailed documentation that includes this code sample, see the following:\n\n- [Connecting to a Redis instance from Cloud Run functions](/memorystore/docs/redis/connect-redis-instance-functions)\n\nCode sample\n-----------\n\n### Go\n\n\nTo authenticate to Cloud Run functions, set up Application Default Credentials.\nFor more information, see\n\n[Set up authentication for a local development environment](/docs/authentication/set-up-adc-local-dev-environment).\n\n\n // Package visitcount provides a Cloud Function that connects\n // to a managed Redis instance.\n package visitcount\n\n import (\n \t\"errors\"\n \t\"fmt\"\n \t\"log\"\n \t\"net/http\"\n \t\"os\"\n\n \t\"github.com/GoogleCloudPlatform/functions-framework-go/functions\"\n \t\"github.com/gomodule/redigo/redis\"\n )\n\n var redisPool *redis.Pool\n\n func init() {\n \t// Register the HTTP handler with the Functions Framework\n \tfunctions.HTTP(\"VisitCount\", visitCount)\n }\n\n // initializeRedis initializes and returns a connection pool\n func initializeRedis() (*redis.Pool, error) {\n \tredisHost := os.Getenv(\"REDISHOST\")\n \tif redisHost == \"\" {\n \t\treturn nil, errors.New(\"REDISHOST must be set\")\n \t}\n \tredisPort := os.Getenv(\"REDISPORT\")\n \tif redisPort == \"\" {\n \t\treturn nil, errors.New(\"REDISPORT must be set\")\n \t}\n \tredisAddr := fmt.Sprintf(\"%s:%s\", redisHost, redisPort)\n\n \tconst maxConnections = 10\n \treturn &redis.Pool{\n \t\tMaxIdle: maxConnections,\n \t\tDial: func() (redis.Conn, error) {\n \t\t\tc, err := redis.Dial(\"tcp\", redisAddr)\n \t\t\tif err != nil {\n \t\t\t\treturn nil, fmt.Errorf(\"redis.Dial: %w\", err)\n \t\t\t}\n \t\t\treturn c, err\n \t\t},\n \t}, nil\n }\n\n // visitCount increments the visit count on the Redis instance\n // and prints the current count in the HTTP response.\n func visitCount(w http.ResponseWriter, r *http.Request) {\n \t// Initialize connection pool on first invocation\n \tif redisPool == nil {\n \t\t// Pre-declare err to avoid shadowing redisPool\n \t\tvar err error\n \t\tredisPool, err = initializeRedis()\n \t\tif err != nil {\n \t\t\tlog.Printf(\"initializeRedis: %v\", err)\n \t\t\thttp.Error(w, \"Error initializing connection pool\", http.StatusInternalServerError)\n \t\t\treturn\n \t\t}\n \t}\n\n \tconn := redisPool.Get()\n \tdefer conn.Close()\n\n \tcounter, err := redis.Int(conn.Do(\"INCR\", \"visits\"))\n \tif err != nil {\n \t\tlog.Printf(\"redis.Int: %v\", err)\n \t\thttp.Error(w, \"Error incrementing visit count\", http.StatusInternalServerError)\n \t\treturn\n \t}\n \tfmt.Fprintf(w, \"Visit count: %d\", counter)\n }\n\n### Node.js\n\n\nTo authenticate to Cloud Run functions, set up Application Default Credentials.\nFor more information, see\n\n[Set up authentication for a local development environment](/docs/authentication/set-up-adc-local-dev-environment).\n\n\n const functions = require('@google-cloud/functions-framework');\n const redis = require('redis');\n\n const REDISHOST = process.env.REDISHOST || 'localhost';\n const REDISPORT = process.env.REDISPORT || 6379;\n\n const redisClient = redis.createClient({\n socket: {\n host: REDISHOST,\n port: REDISPORT,\n },\n });\n redisClient.on('error', err =\u003e console.error('ERR:REDIS:', err));\n redisClient.connect();\n\n functions.http('visitCount', async (req, res) =\u003e {\n try {\n const response = await redisClient.incr('visits');\n res.writeHead(200, {'Content-Type': 'text/plain'});\n res.end(`Visit count: ${response}`);\n } catch (err) {\n console.log(err);\n res.status(500).send(err.message);\n }\n });\n\n### Python\n\n\nTo authenticate to Cloud Run functions, set up Application Default Credentials.\nFor more information, see\n\n[Set up authentication for a local development environment](/docs/authentication/set-up-adc-local-dev-environment).\n\n\n import os\n\n import functions_framework\n import redis\n\n redis_host = os.environ.get(\"REDISHOST\", \"localhost\")\n redis_port = int(os.environ.get(\"REDISPORT\", 6379))\n redis_client = redis.StrictRedis(host=redis_host, port=redis_port)\n\n\n @functions_framework.http\n def visit_count(request):\n value = redis_client.incr(\"visits\", 1)\n return f\"Visit count: {value}\"\n\nWhat's next\n-----------\n\n\nTo search and filter code samples for other Google Cloud products, see the\n[Google Cloud sample browser](/docs/samples?product=functions)."]]