我想限制在我的AWS Lambda中调用AWS参数存储的次数。使用全局变量,我在第一次调用参数存储时将参数存储值缓存起来。
main.py
import os
import boto3
redis_password = None
def get_redis_password():
global redis_password
if not redis_password:
client = boto3.client("ssm")
redis_password = client.get_parameter(
Name=f"{os.environ["ENV"]}.redis-cache.password",
WithDecryption=True
)
return redis_password["Parameter"]["Value"]
def lambda_handler(event, context):
get_redis_password()
但是,如果要缓存多个参数存储值,则必须创建多个全局变量和if not [INSERT_GLOBAL_VARIABLE]
检查。例如:
main.py
import os
import boto3
redis_password = None
another_parameter_store_value = None
def get_redis_password():
global redis_password
if not redis_password:
client = boto3.client("ssm")
redis_password = client.get_parameter(
Name=f"{os.environ["ENV"]}.redis-cache.password",
WithDecryption=True
)
return redis_password["Parameter"]["Value"]
def get_another_parameter_store_value():
global another_parameter_store_value
if not another_parameter_store_value:
client = boto3.client("ssm")
another_parameter_store_value = client.get_parameter(
Name=f"{os.environ["ENV"]}.another.parameter.store.key",
WithDecryption=True
)
return redis_password["Parameter"]["Value"]
def lambda_handler(event, context):
get_redis_password()
get_another_parameter_store_value()
为了解决此问题,我创建了一个参数存储实用程序。
parameter_util.py
import os
import boto3
class ParameterUtil:
def __init__(self):
self.boto_client = boto3.client("ssm")
def get_parameter(self, parameter_path):
response = self.boto_client.get_parameter(
Name=f"{os.environ['ENV']}.{parameter_path}", WithDecryption=True
)
return response["Parameter"]["Value"]
我的理论是,通过将AWS Boto客户端实例化为实例变量,它将缓存整个Boto客户端对象。然后,将使用缓存的Boto客户端调用get_parameter
。例如:
main.py
import os
import boto3
from parameter_util import ParameterUtil
redis_password = None
def get_redis_password():
global redis_password
if not redis_password:
client = boto3.client("ssm")
redis_password = client.get_parameter(
Name=f"{os.environ["ENV"]}.redis-cache.password",
WithDecryption=True
)
return redis_password["Parameter"]["Value"]
def lambda_handler(event, context):
param_util = ParameterUtil()
param_util.get_parameter(".redis-cache.password")
param_util.get_parameter(".another.parameter.store.key")
但是,我不确定是否能解决问题。
当调用get_parameter
时,缓存Boto客户端是否导致每个参数仅对参数存储进行一次调用?还是我在错误的地方进行优化?
我喜欢这种方法。我可能建议将其抽象为类似这样的内容:
main.py
parameter_store_values = {}
client = boto3.client("ssm")
def lookup_function(key):
global parameter_store_values
global client
if parameter_store_values.get(key) is None:
value = client.get_parameter(
Name=key,
WithDecryption=True)["Parameter"]["Value"]
parameter_store_values[key] = value
return value
def lambda_handler(event, context):
redis_password = lookup_function(f"{os.environ["ENV"]}.redis-cache.password")
another_parameter_store_key = lookup_function(f"{os.environ["ENV"]}.another.parameter.store.key")