Connect to a Redis instance from Cloud Run functions

// Package visitcount provides a Cloud Function that connects
// to a managed Redis instance.
packagevisitcount
import(
"errors"
"fmt"
"log"
"net/http"
"os"
"github.com/GoogleCloudPlatform/functions-framework-go/functions"
"github.com/gomodule/redigo/redis"
)
varredisPool*redis.Pool
funcinit(){
// Register the HTTP handler with the Functions Framework
functions.HTTP("VisitCount",visitCount)
}
// initializeRedis initializes and returns a connection pool
funcinitializeRedis()(*redis.Pool,error){
redisHost:=os.Getenv("REDISHOST")
ifredisHost==""{
returnnil,errors.New("REDISHOST must be set")
}
redisPort:=os.Getenv("REDISPORT")
ifredisPort==""{
returnnil,errors.New("REDISPORT must be set")
}
redisAddr:=fmt.Sprintf("%s:%s",redisHost,redisPort)
constmaxConnections=10
return&redis.Pool{
MaxIdle:maxConnections,
Dial:func()(redis.Conn,error){
c,err:=redis.Dial("tcp",redisAddr)
iferr!=nil{
returnnil,fmt.Errorf("redis.Dial: %w",err)
}
returnc,err
},
},nil
}
// visitCount increments the visit count on the Redis instance
// and prints the current count in the HTTP response.
funcvisitCount(whttp.ResponseWriter,r*http.Request){
// Initialize connection pool on first invocation
ifredisPool==nil{
// Pre-declare err to avoid shadowing redisPool
varerrerror
redisPool,err=initializeRedis()
iferr!=nil{
log.Printf("initializeRedis: %v",err)
http.Error(w,"Error initializing connection pool",http.StatusInternalServerError)
return
}
}
conn:=redisPool.Get()
deferconn.Close()
counter,err:=redis.Int(conn.Do("INCR","visits"))
iferr!=nil{
log.Printf("redis.Int: %v",err)
http.Error(w,"Error incrementing visit count",http.StatusInternalServerError)
return
}
fmt.Fprintf(w,"Visit count: %d",counter)
}

constfunctions=require('@google-cloud/functions-framework');
constredis=require('redis');
constREDISHOST=process.env.REDISHOST||'localhost';
constREDISPORT=process.env.REDISPORT||6379;
constredisClient=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{
constresponse=awaitredisClient.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);
}
});

importos
importfunctions_framework
importredis
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
defvisit_count(request):
 value = redis_client.incr("visits", 1)
 return f"Visit count: {value}"