Memorystore for Redis
使用集合让一切井井有条
根据您的偏好保存内容并对其进行分类。
演示连接到代管式 Redis 实例的 Cloud Functions 函数。
深入探索
如需查看包含此代码示例的详细文档,请参阅以下内容:
代码示例
Go
如需向 Cloud Run functions 进行身份验证,请设置应用默认凭证。如需了解详情,请参阅为本地开发环境设置身份验证。
Node.js
如需向 Cloud Run functions 进行身份验证,请设置应用默认凭证。如需了解详情,请参阅为本地开发环境设置身份验证。
Python
如需向 Cloud Run functions 进行身份验证,请设置应用默认凭证。如需了解详情,请参阅为本地开发环境设置身份验证。
如未另行说明,那么本页面中的内容已根据知识共享署名 4.0 许可获得了许可,并且代码示例已根据 Apache 2.0 许可获得了许可。有关详情,请参阅 Google 开发者网站政策。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)."]]