{"value":"#### **前言**\n\n**Amazon** **MemoryDB** **for** **Redis** 和 **[Amazon ElastiCache](https://aws.amazon.com/cn/elasticache/?trk=cndc-detail)** **for** **Redis** 是云上内存数据存储。ElastiCache 通常用作缓存， 而MemoryDB 是一种可持久的数据库，专为具有高性能要求的应用程序而设计。\n\n\n\n客户喜欢 **Redis** 作为内存中数据引擎。随着使用和访问的数据呈指数级增长，充分利用可用内存变得越来越重要。在这篇博文中，我提供了多种策略以及代码片段，以帮助您在使用 MemoryDB for Redis 和 ElastiCache for Redis 时减少应用程序的内存消耗。这有助于优化成本，并允许您在现有集群的实例中容纳更多数据。\n\n\n\n在进行这些优化之前，请记住 ElastiCache for Redis 支持**数据分层**，它会自动将数据放置在内存和本地高性能固态硬盘 (SSD) 中。数据分层非常适合定期访问最高 20% 数据集的应用程序。ElastiCache for Redis 提供了一种便捷的方式，可以以较低的成本将集群扩展到最高 1 PB 的数据。它可以实现**每 GB 容量节省 60% 以上**，同时对定期访问其数据子集的工作负载的性能影响最小。ElastiCache for Redis 还支持**自动扩展**，**通过添加或移除分片或副本节点来自动水平调整集群。**\n\n\n#### **先决条件**\n\n\n在此演练中，您需要具备以下各项：\n\n\n\n一个**亚马逊云科技账户**（您可以使用 Amzaon Free Tier）\n\n一个 ElastiCache for Redis 或 MemoryDB 集群（一个实例就足够了）\n\n您的本地计算机或可连接到集群的远程环境（如 **Amazon Cloud9**）\n\n**远程连接**到您的实例的 redis-cli 客户端\n\n具有以下库的 Python 3.5 或更高版本\n亚马逊云科技账户：\n[https://portal.aws.amazon.com/billing/signup#/start/email](https://portal.aws.amazon.com/billing/signup#/start/email)\nAmzaon Free Tier：\n[https://aws.amazon.com/cn/memorydb/](https://aws.amazon.com/cn/memorydb/)\n远程连接：\n[https://docs.aws.amazon.com/memorydb/latest/devguide/getting-startedclusters.connecttonode.html](https://docs.aws.amazon.com/memorydb/latest/devguide/getting-startedclusters.connecttonode.html)\n要运行这篇博文中的一些示例，您需要以下 Python 库：\n```\\npip install redis-py-cluster # 用于连接到您的 elasticache 或 memorydb 集群\\npip install faker # 用于模拟不同类型的数据\\npip install msgpack # 用于以二进制格式序列化复杂数据\\npip install lz4 pyzstd # 用于压缩长数据类型和短数据类型\\n```\n为知道使用了多少内存，redis-cli 提供了 memory usage 命令：\n```\\nredis-cli -h <your_instance_endpoint> --tls -p 6379\\n>>memory usage \\"my_key\\"\\n(integer) 153\\n```\n要从 Python 连接到我们的 Redis 集群，我们使用 redis-py-cluster（[https://redis-py-cluster.readthedocs.io/en/stable/](https://redis-py-cluster.readthedocs.io/en/stable/)）。在我们的示例中，为了简单起见，我们忽略了 RedisCluster对象的创建。要检查您是否已连接到 Redis 实例，可以使用以下代码：\n```\\n>>from rediscluster import RedisCluster\\n>>HOST=\\"<Your host URL>\\"\\n>>redis_db = RedisCluster(host=HOST, port=6379, ssl=True)\\n```\n如果您要执行多个操作，请考虑使用**管道**（[https://redis-py-cluster.readthedocs.io/en/stable/pipelines.html](https://redis-py-cluster.readthedocs.io/en/stable/pipelines.html)）。管道允许您批量处理多个操作并保存多次网络行程以获得更高的性能。请参阅以下代码：\n```\\n>>pipe = redis_db.pipeline()\\n>>pipe.set(key_1, value_1)\\n...\\n>>pipe.set(key_n, value_n)\\n>>pipe.execute()\\n```\n要在将项插入到 Redis 之前检查其大小，我们使用以下代码：\n```\\n>>import sys\\n>>x = 2 # x 可以是任何 python 对象\\n>>sys.getsizeof(x) # 返回对象 x 的大小（以字节为单位）\\n24\\n```\n为了模拟更真实的数据，我们使用 Faker（[https://faker.readthedocs.io/en/master/](https://faker.readthedocs.io/en/master/)） 库：\n```\\n>>from faker import Faker\\n>>fake = Faker()\\n>>fake.name()\\n'Lucy Cechtelar'\\n>>fake.address()\\n'426 Jordy Lodge'\\n```\n**基本优化**\n\n\n\n在进行高级优化之前，我们会应用基本优化。这些都是简单的操作，所以我们不在这篇博文中提供代码。\n\n\n\n在我们的示例中，我们假设有一个很大的**键值对列表**。作为间， —> 作为键。作为值，我们有访问次数、报告的名称和最近的操作计数器：\n```\\nIP:123.82.92.12 → {\\"visits\\":\\"1\\", \\"name\\":\\"John Doe\\", \\"recent_actions\\": \\"visit,checkout,purchase\\"},\\nIP:3.30.7.124 → {\\"visits\\":\\"12\\", \\"name\\":\\"James Smith\\", \\"recent_actions\\": \\"purchase,refund\\"},\\n...\\nIP:121.66.3.5 → {\\"visits\\":\\"5\\", \\"name\\":\\"Peter Parker\\", \\"recent_actions\\": \\"visit,visit\\"}\\n```\n使用以下代码以编程方式插入这些内容：\n```\\n使用以下代码以编程方式插入这些内容：\\n\\nredis_db.hset(\\"IP:123.82.92.12\\", {\\"visits\\":\\"1\\", \\"name\\":\\"John Doe\\", \\"recent_actions\\": \\"visit,checkout,purchase\\"})\\nredis_db.hset(\\"IP:3.30.7.124\\", {\\"visits\\":\\"12\\", \\"name\\":\\"James Smith\\", \\"recent_actions\\": \\"purchase,refund\\"})\\n...\\nredis_db.hset(\\"IP:121.66.3.5\\", {\\"visits\\":\\"5\\", \\"name\\":\\"Peter Parker\\", \\"recent_actions\\": \\"visit,visit\\"})\\n```\n::: hljs-center\n\n#### **缩短字段名称**\n\n:::\n\n\n\n\nRedis 字段名称在每次使用时都会消耗内存，因此您可以通过使名称尽可能简短来节省空间。在前面的示例中，我们可能希望使用 v，而不是 visits 作为字段名称。同样，我们可以使用 n 代替 name，用 r 代替 recent_actions。我们也可以将键名称缩短为 i 而不是 IP。\n\n\n\n在字段本身中，您还可以使用符号缩短常用词。我们可以将最近的操作切换为首字符（v 而不是 visit）。\n\n\n\n以下代码是我们之前的示例在简化后的样子：\n```\\ni:123.82.92.12 → {\\"v\\":\\"1\\", \\"n\\":\\"John Doe\\", \\"r\\": \\"vcp\\"},\\ni:3.30.7.124 → {\\"v\\":\\"12\\", \\"n\\":\\"James Smith\\", \\"r\\": \\"pr\\"},\\n...\\ni:121.66.3.5 → {\\"v\\":\\"5\\", \\"n\\":\\"Peter Parker\\", \\"r\\": \\"vv\\"}\\n```\n在我们的具体示例中，这将节省 23% 的内存。\n\n\n\n::: hljs-center\n\n#### **使用位置指示数据类型**\n\n:::\n\n\n\n\n如果所有字段都存在，我们可以使用列表而不是哈希，位置告诉我们字段名称是什么。这允许我们完全删除字段名称。请参阅以下代码：\n```\\ni:123.82.92.12 → [1, \\"John Doe\\", \\"vcp\\"],\\ni:3.30.7.124 → [12, \\"James Smith\\", \\"pr\\"],\\n...\\ni:121.66.3.5 → [5, \\"Peter Parker\\", \\"vv\\"]\\n```\n在我们的案例中，这将额外**节省 14%** 的内存。\n\n\n\n::: hljs-center\n\n#### **序列化复杂类型**\n\n:::\n\n\n有多种方法可以序列化复杂的对象，这使您可以高效地存储这些对象。大多数语言都有自己的序列化库（Python 中的 pickle、Java 中的 Serializable 等等）。有些库可以跨语言工作，而且通常空间效率更高，例如 ProtoBuff 或 MsgPack。\n以下代码显示了一个使用 MsgPack （[https://msgpack.org/](https://msgpack.org/)）的示例：\n```\\nimport msgpack\\ndef compress(data: object) -> bytes:\\n return msgpack.packb(data, use_bin_type=True) \\ndef write(key, value):\\n key_bytes = b'i:'+compress(key) # 我们也可以对键进行序列化\\n value_bytes = compress(value)\\n redis_db.set(key_bytes, value_bytes)\\nwrite([121,66,3,5] , [134,\\"John Doe\\",\\"vcp\\"])\\n```\n在本例中，原始对象为 73 字节，而序列化对象为 49 字节（空间减少 33%）。\n\n\n\n为了恢复该值，MsgPack 非常方便，返回准备使用的 Python 对象：\n```\\ndef decompress(data: bytes) -> object:\\n return msgpack.unpackb(data, raw=False)\\ndef read(key):\\n value_bytes = redis_db.get(key)\\n return decompress(value_bytes)\\n# 现在我们可以恢复值对象了\\nvalue = read([121,66,3,5])\\n```\n::: hljs-center\n\n#### **特定于 Redis 的优化**\n\n:::\n\n\n\n\n为了提供快速访问和 TTL 等功能，Redis 可能需要在内存中使用数据本身所需的额外空间。接下来的两部分可帮助我们将额外开销降至最低。然后我们展示一些可以进一步帮助减少内存的概率结构。\n\n\n\n**从字符串或列表移动到哈希**\n\n\n\n在最初的示例中，我们将许多小字符串存储为独立列表。Redis 上的每个条目都有 60 字节（没有过期）或 100 字节（有过期）的额外空间，如果我们存储数百万项（1 亿个条目 x 100 字节 = 10 GB 的开销），这将很有意义。在第一个示例中，它们存储为 Redis 列表：\n```\\n\\"i:123.82.92.12\\" → [1, \\"John Doe\\", \\"vcp\\"],\\n\\"i:3.30.7.124\\" → [12, \\"James Smith\\", \\"pr\\"],\\n...\\n\\"i:121.66.3.5\\" → [5, \\"Peter Parker\\", \\"vv\\"]\\n```\n在最终的优化中，所有字段都存储在一个哈希中：\n```\\nmydata → {\\n \\"i:123.82.92.12\\" : \\"1, John Doe, vcp\\",\\n \\"i:3.30.7.124\\" : \\"12, James Smith, pr\\",\\n ...\\n \\"i:121.66.3.5\\" : \\"5, Peter Parker, vv\\"\\n}\\n```\n这使我们可以为每个条目节省 90 字节。在前面的示例中，假定每个条目都相对较小，表示内存使用量减少了 40%。\n\n\n\n**转换为较小的哈希（使用压缩列表）**\n\n\n\nRedis 中的哈希可以在内存中编码为哈希表或压缩列表（Redis 7 中的列表包）。使用哪个参数取决于**参数组**（[https://docs.aws.amazon.com/AmazonElastiCache/latest/red-ug/ParameterGroups.html](https://docs.aws.amazon.com/AmazonElastiCache/latest/red-ug/ParameterGroups.html)）中的两个参数：\n```\\nhash-max-ziplist-value（默认为 64）\\nhash-max-ziplist-entries（默认为 512）\\n```\n如果键的任何值超过两个配置，它将自动存储为哈希表而不是压缩列表。哈希表使用的内存量是压缩列表的两倍，但对于大哈希可能会更快。其想法是使用压缩列表，同时将每个哈希中的项数保持在合理的数字。\n\n\n\n为了在压缩列表中高效地存储项，我们将单个大哈希迁移到许多大小相似的小哈希中：\n```\\nmydata:001 → {\\n i:12.82.92.12 : [1, \\"John Doe\\", \\"vcp\\"],\\n i:34.30.7.124 : [12, \\"James Smith\\", \\"pr\\"],\\n i:121.66.3.5 : [5, \\"Peter Parker\\", \\"vv\\"]\\n}\\nmydata:002 → {\\n i:1.82.92.12 : [1, \\"John Doe\\", \\"vcp\\"],\\n i:9.30.7.124 : [12, \\"James Smith\\", \\"pr\\"],\\n i:11.66.3.5 : [5, \\"Peter Parker\\", \\"vv\\"]\\n}\\n...\\nmydata:999 → {\\n i:23.82.92.12 : [1, \\"John Doe\\", \\"vcp\\"],\\n i:33.30.7.124 : [12, \\"James Smith\\", \\"pr\\"],\\n i:21.66.3.5 : [5, \\"Peter Parker\\", \\"vv\\"]\\n}\\n```\n为了实现这种空间效率，我们使用以下代码：\n```\\nimport binascii\\nSHARDS = 1000 # 存储桶数，目标是每个桶少于 1000 项\\nPREFIX = \\"mydata:\\" # 用于轻松地在我们的数据库中查找数据的前缀\\n\\ndef get_shard_key(key: bytes) -> str:\\n \\"\\"\\"\\n 根据 CRC 和分片数量计算给定键的 shard_key。\\n \\"\\"\\"\\n shard_id = binascii.crc32(key) % SHARDS # 使用模数精确获得 1000 个存储桶\\n return PREFIX+str(shard_id)\\n\\ndef write(key, value):\\n shard_key = get_shard_key(key) # 分片是键的函数 \\n redis_db.hset(shard_key, key, value)\\n\\nwrite(b'i:21.66.3.5', b'1, John Doe, vcp')\\n```\n要读回这些值，我们使用以下代码：\n```\\ndef read(key):\\n shard_key = get_shard_key(sample_key)\\n return redis_db.hget(shard_key, sample_key)\\n\\nvalue = read(sample_key)\\n```\n以下屏幕截图显示了如何在 [Amazon ElastiCache](https://aws.amazon.com/cn/elasticache/?trk=cndc-detail) for Redis 控制台上编辑参数组的示例。\n\n为了确保您实际上使用的是压缩列表，您可以使用 object encoding 命令：\n```\\n>>object encoding \\"mydata:001\\"\\n\\"ziplist\\"\\n>>memory usage \\"mydata:001\\"\\n(integer) 5337\\n```\n内存使用量也应该比我们存储为哈希列表时少 40% 左右。如果您没有看到类型为压缩列表，请检查两个参数并确保两个条件都得到满足。\n\n\n\n**使用概率结构**\n\n\n如果您需要计算集合中的项数，但不需要精确，**HyperLogLOG **（[https://redis.com/redis-best-practices/counting/hyperloglog/](https://redis.com/redis-best-practices/counting/hyperloglog/)）是一种原生支持的概率数据结构，用于计算集合中的唯一项。**HyperLogLog 算法**（[https://en.wikipedia.org/wiki/HyperLogLog](https://en.wikipedia.org/wiki/HyperLogLog)）能够使用 1.5 kB 的内存以 2% 的典型准确度（标准误差）估计超过 109 的基数。\n\n\n\n**Bloom 筛选器**（[https://en.wikipedia.org/wiki/Bloom_filter](https://en.wikipedia.org/wiki/Bloom_filter)）也是一种高度节省空间和时间的概率数据结构。尽管原生不支持，但可以实现。Bloom 筛选器用于测试元素是否是误报概率很小（但没有误报）的集合的成员。它允许您以 1% 的误报概率存储少于 10 位的项。\n\n\n\n如果您需要简单地检查具有最小冲突机会的等效性，您可以存储内容的哈希值。例如，您可以使用 xxHash （[https://github.com/Cyan4973/xxHash](https://github.com/Cyan4973/xxHash)）之类的快速、非加密哈希函数：\n```\\n>>import xxhash\\n>>hashed_content = xxh32_intdigest(b'134, John William Doe, vcpvvcppvvcc')\\n>>redis_db.set(\\"my_key\\",hashed_content)\\n```\n没有办法恢复原始值（除非您把它存储在其他地方），但是我们可以使用哈希版本来检查是否存在：\n```\\n>>new_content = xxh32_intdigest(b'131, Peter Doe, vcpvvcppvvcc')\\n>>if redis_db.get(\\"my_key\\") == new_content:\\n>> print(\\"No need to store\\")\\n```\n::: hljs-center\n\n#### **数据压缩**\n\n:::\n\n\n\n\n减少内存消耗的一种最简单的方法是减小键和值的大小。这不是 Redis 所特有的，但特别适用于它。\n\n通常，Redis（以及半结构化和结构化数据库）的压缩与文件压缩有很大不同。原因是，在 Redis 中，我们通常存储短字段。\n\n\n\n**长数据的压缩**\n\n\n\n要压缩长数据，您可以使用常用的压缩算法，例如 Gzip、LZO 或 Snappy。在本例中，我们使用了 **LZ4**（[https://github.com/lz4/lz4](https://github.com/lz4/lz4)），它在速度和压缩比之间取得了很好的平衡：\n```\\nimport lz4.frame\\nfrom faker import Faker\\nfake = Faker()\\n\\ndef compress(text: str)-> bytes:\\n text_bytes = str.encode(text) # 转换为字节\\n return lz4.frame.compress(text_bytes)\\n\\ntext = fake.paragraph(nb_sentences=100) # 生成包含 100 个句子的段落\\ncompressed_bytes = compress(text)\\n```\n要恢复原始值，我们可以简单地将压缩后的字节传递给 LZ4 库\n```\\ndef decompress(data: bytes) -> str:\\n return lz4.frame.decompress(data)\\n\\noriginal = decompress(compressed_bytes)\\n```\n在本例中，压缩后的字符串比压缩前小 20%。请注意，对于小字符串（通常存储在数据库中），这不太可能产生好的结果。如果您的数据非常大，您可以考虑将其存储在其他地方，例如 **[Amazon Simple Storage Service](https://aws.amazon.com/cn/s3/?trk=cndc-detail) **([Amazon S3](https://aws.amazon.com/cn/s3/?trk=cndc-detail))（[https://aws.amazon.com/cn/s3/](https://aws.amazon.com/cn/s3/)）。\n\n\n\n如前所述，对于小字符串（在 Redis 中更为常见），这不会产生好的结果。我们可以尝试压缩值组（例如值分片），但这会增加代码的复杂性，因此接下来的选项更有可能对我们有所帮助。\n\n\n\n#### **自定义基础编码**\n\n\n\n减少所用空间的一种方法是使用特定数据类型的有限字符范围。例如，我们的应用程序可能会强制要求用户名只能包含小写字母 (a-z) 和数字 (0-9)。如果是这样的话，**base36 **（[https://en.wikipedia.org/wiki/Base36](https://en.wikipedia.org/wiki/Base36)）编码比简单地将它们存储为字符串更有效。\n\n\n\n您也可以根据自己的字母创建自己的基础。在本例中，我们假设正在记录石头剪刀布游戏玩家的所有动作。为了有效地对其进行编码，我们将每个动作存储为单个字符串。在我们的示例中，我们将石头表示为 0，将布表示为 1，剪刀表示为 2。然后，我们可以通过将其存储为使用所有潜在值的整数来进一步压缩它：\n```\\n>>BASE=3\\n>>ALPHABET=\\"012\\"\\n>>player_moves=b\\"20110012200120000110\\" # 0 是石头，1 是布，2 是剪刀\\n>>compressed=int(player_moves, BASE) # 转换为 base-3 数字\\n2499732264\\n```\n虽然原始 player_moves 字符串需要 20 字节，但压缩后的整数可以存储在 4 字节中（减少 75% 的空间）。解压缩稍微复杂一些：\n```\\ndef decompress(s) -> str:\\n res = \\"\\"\\n while s:\\n res+=ALPHABET[s%BASE]\\n s//= BASE\\n return res[::-1] or \\"0\\"\\n\\ndecompress(2499732264) # 这将返回“20110012200120000110”\\n```\n使用 base-36 可以减少约 64% 的使用空间。有一些**常用的编码**（[https://en.wikipedia.org/wiki/Binary-to-text_encoding](https://en.wikipedia.org/wiki/Binary-to-text_encoding)）和一些**易于使用的库**（[https://www.npmjs.com/package/base-x](https://www.npmjs.com/package/base-x)）。\n\n\n**\n使用域字典压缩短字符串**\n\n\n\n大多数压缩算法（例如 Gzip、LZ4、Snappy）在压缩小字符串（例如人名或 URL）方面效果不佳。这是因为他们在压缩数据的同时了解数据。\n\n\n\n一种有效的技巧是使用**预训练的字典**（[https://pyzstd.readthedocs.io/en/latest/#dictionary](https://pyzstd.readthedocs.io/en/latest/#dictionary)）。在以下示例中，我们使用 Zstandard 来训练用于压缩和解压缩作业名称的字典：\n```\\nimport pyzstd \\nfrom faker import Faker\\nfake = Faker()\\nFaker.seed(0)\\n\\ndef data() -> list:\\n samples = []\\n for i in range(1024): # 使用 1000+ 个作业进行训练\\n tmp_bytes = str.encode(fake.job())\\n samples.append(tmp_bytes)\\n return samples\\n\\njob_dictionary = pyzstd.train_dict(data(), 100*1024)\\n```\n拥有 job_dictionary 后，压缩任何随机作业都很简单：\n```\\ndef compress(job_string) -> bytes:\\n return pyzstd.compress(job_string, 10, job_dictionary)\\n\\ncompressed_job = compress(b'Armed forces technical officer') # 我们可以压缩任何作业\\n```\n解压缩也很简单，但需要原始字典：\n```\\nuncompressed_job = pyzstd.decompress(compressed_job, job_dictionary)\\n```\n在这个简单的示例中，最初的未压缩作业是 30 字节，而压缩后的作业是 21 字节（节省了 30% 的空间）。\n\n\n**适用于短字段的其他编码技术**\n\n\n\n短字符串压缩在文件压缩中很常见，但您可以根据用例使用其他方法。您可以从 **[Amazon Redshift](https://aws.amazon.com/cn/redshift/?trk=cndc-detail) 压缩编码**中获得灵感：\n\nByte-dictionary — 如果数据的基数很小，则可以为符号而不是完整字符串编码索引。这方面的一个示例是客户所在的国家/地区。由于国家/地区数量较少，因此您可以通过仅存储国家/地区的索引来节省大量空间。\n\nDelta — 购买时间之类的内容可能会按差异使用完整时间戳进行存储，差异会更小。\n\nMostly — 当列的数据类型大于大多数存储值所需的值时，Mostly 编码很有用。\n\nRun length — Run length 编码将连续重复的值替换为由该值和连续出现次数（运行长度）组成的标记。\n\nText255 和 text32k — Text255 和 text32k 编码对于压缩经常出现相同单词的字符串字段非常有用。\n\n\n\n通常，短字符串压缩受益于结构信息约束（例如，IPv4 由 0-255 之间的四个数字组成）和分发信息（例如，许多使用者电子邮件都有一个免费域，如 gmail.com、yahoo.com 或 hotmail.com）。\n[Amazon Redshift](https://aws.amazon.com/cn/redshift/?trk=cndc-detail)：\n\n[https://aws.amazon.com/cn/redshift/](https://aws.amazon.com/cn/redshift/)\n\n压缩编码：\n\n[https://docs.aws.amazon.com/redshift/latest/dg/c_Compression_encodings.html](https://docs.aws.amazon.com/redshift/latest/dg/c_Compression_encodings.html)\n\nByte-dictionary：\n\n[https://docs.aws.amazon.com/redshift/latest/dg/c_Byte_dictionary_encoding.html](https://docs.aws.amazon.com/redshift/latest/dg/c_Byte_dictionary_encoding.html)\n\nDelta：\n\n[https://docs.aws.amazon.com/redshift/latest/dg/c_Delta_encoding.html](https://docs.aws.amazon.com/redshift/latest/dg/c_Delta_encoding.html)\n\nMostly：\n\n[https://docs.aws.amazon.com/redshift/latest/dg/c_Delta_encoding.html](https://docs.aws.amazon.com/redshift/latest/dg/c_MostlyN_encoding.html)\n\nRun length：\n\n[https://docs.aws.amazon.com/redshift/latest/dg/c_Delta_encoding.html](https://docs.aws.amazon.com/redshift/latest/dg/c_Runlength_encoding.html)\n\nText255 和 text32k：\n\n[https://docs.aws.amazon.com/redshift/latest/dg/c_Text255_encoding.html](https://docs.aws.amazon.com/redshift/latest/dg/c_Text255_encoding.html)\n::: hljs-center\n\n#### **决策表**\n\n:::\n\n\n\n\n下表列出了应用每种技术的摘要和必要要求。\n\n::: hljs-center\n\n#### **结论**\n\n:::\n\n\n\n\n在这篇博文中，我向您展示了优化 Redis 实例内存消耗的多种方法。这可能会对成本和性能产生积极影响。任何优化都会在用于读写的空间和时间之间进行权衡。根据数据的存储方式，可能会丢失一些原生 Redis 功能（例如驱逐策略）。Redis 也提供了一个很好的内存优化指南（[https://docs.redis.com/latest/ri/memory-optimizations/](https://docs.redis.com/latest/ri/memory-optimizations/)），与这篇博文有些重叠。\n\n\n\n您如何有效地将数据存储在与 Redis 兼容的数据库中？请在评论部分告诉我。\n\n**本篇作者**\n\nRoger Sindreu\n\nAmazon Web Services 的解决方案构架师。他是一名数据库工程师，在过去的 20 年中一直领导工程团队。他的兴趣是 AI/ML、数据库、FSI 以及与 亚马逊云科技相关的一切。\n\n[阅读原文](https://aws.amazon.com/cn/blogs/china/optimize-application-memory-usage-on-amazon-elasticache-for-redis-and-amazon-memorydb-for-redis/)","render":"<h4><a id=\\"_0\\"></a><strong>前言</strong></h4>\\n<p><strong>Amazon</strong> <strong>MemoryDB</strong> <strong>for</strong> <strong>Redis</strong> 和 <strong>Amazon ElastiCache</strong> <strong>for</strong> <strong>Redis</strong> 是云上内存数据存储。ElastiCache 通常用作缓存， 而MemoryDB 是一种可持久的数据库，专为具有高性能要求的应用程序而设计。</p>\\n<p>客户喜欢 <strong>Redis</strong> 作为内存中数据引擎。随着使用和访问的数据呈指数级增长，充分利用可用内存变得越来越重要。在这篇博文中，我提供了多种策略以及代码片段，以帮助您在使用 MemoryDB for Redis 和 ElastiCache for Redis 时减少应用程序的内存消耗。这有助于优化成本，并允许您在现有集群的实例中容纳更多数据。</p>\\n<p>在进行这些优化之前，请记住 ElastiCache for Redis 支持<strong>数据分层</strong>，它会自动将数据放置在内存和本地高性能固态硬盘 (SSD) 中。数据分层非常适合定期访问最高 20% 数据集的应用程序。ElastiCache for Redis 提供了一种便捷的方式，可以以较低的成本将集群扩展到最高 1 PB 的数据。它可以实现<strong>每 GB 容量节省 60% 以上</strong>，同时对定期访问其数据子集的工作负载的性能影响最小。ElastiCache for Redis 还支持<strong>自动扩展</strong>，<strong>通过添加或移除分片或副本节点来自动水平调整集群。</strong></p>\\n<h4><a id=\\"_13\\"></a><strong>先决条件</strong></h4>\\n<p>在此演练中，您需要具备以下各项：</p>\n<p>一个<strong>亚马逊云科技账户</strong>（您可以使用 Amzaon Free Tier）</p>\\n<p>一个 ElastiCache for Redis 或 MemoryDB 集群（一个实例就足够了）</p>\n<p>您的本地计算机或可连接到集群的远程环境（如 <strong>Amazon Cloud9</strong>）</p>\\n<p><strong>远程连接</strong>到您的实例的 redis-cli 客户端</p>\\n<p>具有以下库的 Python 3.5 或更高版本<br />\\n亚马逊云科技账户：<br />\\n<a href=\\"https://portal.aws.amazon.com/billing/signup#/start/email\\" target=\\"_blank\\">https://portal.aws.amazon.com/billing/signup#/start/email</a><br />\\nAmzaon Free Tier：<br />\\n<a href=\\"https://aws.amazon.com/cn/memorydb/\\" target=\\"_blank\\">https://aws.amazon.com/cn/memorydb/</a><br />\\n远程连接：<br />\\n<a href=\\"https://docs.aws.amazon.com/memorydb/latest/devguide/getting-startedclusters.connecttonode.html\\" target=\\"_blank\\">https://docs.aws.amazon.com/memorydb/latest/devguide/getting-startedclusters.connecttonode.html</a><br />\\n要运行这篇博文中的一些示例，您需要以下 Python 库：</p>\n<pre><code class=\\"lang-\\">pip install redis-py-cluster # 用于连接到您的 elasticache 或 memorydb 集群\\npip install faker # 用于模拟不同类型的数据\\npip install msgpack # 用于以二进制格式序列化复杂数据\\npip install lz4 pyzstd # 用于压缩长数据类型和短数据类型\\n</code></pre>\\n<p>为知道使用了多少内存，redis-cli 提供了 memory usage 命令：</p>\n<pre><code class=\\"lang-\\">redis-cli -h <your_instance_endpoint> --tls -p 6379\\n>>memory usage "my_key"\\n(integer) 153\\n</code></pre>\\n<p>要从 Python 连接到我们的 Redis 集群，我们使用 redis-py-cluster（<a href=\\"https://redis-py-cluster.readthedocs.io/en/stable/\\" target=\\"_blank\\">https://redis-py-cluster.readthedocs.io/en/stable/</a>）。在我们的示例中，为了简单起见，我们忽略了 RedisCluster对象的创建。要检查您是否已连接到 Redis 实例，可以使用以下代码：</p>\\n<pre><code class=\\"lang-\\">>>from rediscluster import RedisCluster\\n>>HOST="<Your host URL>"\\n>>redis_db = RedisCluster(host=HOST, port=6379, ssl=True)\\n</code></pre>\\n<p>如果您要执行多个操作，请考虑使用<strong>管道</strong>（<a href=\\"https://redis-py-cluster.readthedocs.io/en/stable/pipelines.html\\" target=\\"_blank\\">https://redis-py-cluster.readthedocs.io/en/stable/pipelines.html</a>）。管道允许您批量处理多个操作并保存多次网络行程以获得更高的性能。请参阅以下代码：</p>\\n<pre><code class=\\"lang-\\">>>pipe = redis_db.pipeline()\\n>>pipe.set(key_1, value_1)\\n...\\n>>pipe.set(key_n, value_n)\\n>>pipe.execute()\\n</code></pre>\\n<p>要在将项插入到 Redis 之前检查其大小，我们使用以下代码：</p>\n<pre><code class=\\"lang-\\">>>import sys\\n>>x = 2 # x 可以是任何 python 对象\\n>>sys.getsizeof(x) # 返回对象 x 的大小（以字节为单位）\\n24\\n</code></pre>\\n<p>为了模拟更真实的数据，我们使用 Faker（<a href=\\"https://faker.readthedocs.io/en/master/\\" target=\\"_blank\\">https://faker.readthedocs.io/en/master/</a>） 库：</p>\\n<pre><code class=\\"lang-\\">>>from faker import Faker\\n>>fake = Faker()\\n>>fake.name()\\n'Lucy Cechtelar'\\n>>fake.address()\\n'426 Jordy Lodge'\\n</code></pre>\\n<p><strong>基本优化</strong></p>\\n<p>在进行高级优化之前，我们会应用基本优化。这些都是简单的操作，所以我们不在这篇博文中提供代码。</p>\n<p>在我们的示例中，我们假设有一个很大的<strong>键值对列表</strong>。作为间， —> 作为键。作为值，我们有访问次数、报告的名称和最近的操作计数器：</p>\\n<pre><code class=\\"lang-\\">IP:123.82.92.12 → {"visits":"1", "name":"John Doe", "recent_actions": "visit,checkout,purchase"},\\nIP:3.30.7.124 → {"visits":"12", "name":"James Smith", "recent_actions": "purchase,refund"},\\n...\\nIP:121.66.3.5 → {"visits":"5", "name":"Peter Parker", "recent_actions": "visit,visit"}\\n</code></pre>\\n<p>使用以下代码以编程方式插入这些内容：</p>\n<pre><code class=\\"lang-\\">使用以下代码以编程方式插入这些内容：\\n\\nredis_db.hset("IP:123.82.92.12", {"visits":"1", "name":"John Doe", "recent_actions": "visit,checkout,purchase"})\\nredis_db.hset("IP:3.30.7.124", {"visits":"12", "name":"James Smith", "recent_actions": "purchase,refund"})\\n...\\nredis_db.hset("IP:121.66.3.5", {"visits":"5", "name":"Peter Parker", "recent_actions": "visit,visit"})\\n</code></pre>\\n<div class=\\"hljs-center\\">\\n<h4><a id=\\"_104\\"></a><strong>缩短字段名称</strong></h4>\\n</div>\n<p>Redis 字段名称在每次使用时都会消耗内存，因此您可以通过使名称尽可能简短来节省空间。在前面的示例中，我们可能希望使用 v，而不是 visits 作为字段名称。同样，我们可以使用 n 代替 name，用 r 代替 recent_actions。我们也可以将键名称缩短为 i 而不是 IP。</p>\n<p>在字段本身中，您还可以使用符号缩短常用词。我们可以将最近的操作切换为首字符（v 而不是 visit）。</p>\n<p>以下代码是我们之前的示例在简化后的样子：</p>\n<pre><code class=\\"lang-\\">i:123.82.92.12 → {"v":"1", "n":"John Doe", "r": "vcp"},\\ni:3.30.7.124 → {"v":"12", "n":"James Smith", "r": "pr"},\\n...\\ni:121.66.3.5 → {"v":"5", "n":"Peter Parker", "r": "vv"}\\n</code></pre>\\n<p>在我们的具体示例中，这将节省 23% 的内存。</p>\n<div class=\\"hljs-center\\">\\n<h4><a id=\\"_132\\"></a><strong>使用位置指示数据类型</strong></h4>\\n</div>\n<p>如果所有字段都存在，我们可以使用列表而不是哈希，位置告诉我们字段名称是什么。这允许我们完全删除字段名称。请参阅以下代码：</p>\n<pre><code class=\\"lang-\\">i:123.82.92.12 → [1, "John Doe", "vcp"],\\ni:3.30.7.124 → [12, "James Smith", "pr"],\\n...\\ni:121.66.3.5 → [5, "Peter Parker", "vv"]\\n</code></pre>\\n<p>在我们的案例中，这将额外<strong>节省 14%</strong> 的内存。</p>\\n<div class=\\"hljs-center\\">\\n<h4><a id=\\"_152\\"></a><strong>序列化复杂类型</strong></h4>\\n</div>\n<p>有多种方法可以序列化复杂的对象，这使您可以高效地存储这些对象。大多数语言都有自己的序列化库（Python 中的 pickle、Java 中的 Serializable 等等）。有些库可以跨语言工作，而且通常空间效率更高，例如 ProtoBuff 或 MsgPack。<br />\\n以下代码显示了一个使用 MsgPack （<a href=\\"https://msgpack.org/\\" target=\\"_blank\\">https://msgpack.org/</a>）的示例：</p>\\n<pre><code class=\\"lang-\\">import msgpack\\ndef compress(data: object) -> bytes:\\n return msgpack.packb(data, use_bin_type=True) \\ndef write(key, value):\\n key_bytes = b'i:'+compress(key) # 我们也可以对键进行序列化\\n value_bytes = compress(value)\\n redis_db.set(key_bytes, value_bytes)\\nwrite([121,66,3,5] , [134,"John Doe","vcp"])\\n</code></pre>\\n<p>在本例中，原始对象为 73 字节，而序列化对象为 49 字节（空间减少 33%）。</p>\n<p>为了恢复该值，MsgPack 非常方便，返回准备使用的 Python 对象：</p>\n<pre><code class=\\"lang-\\">def decompress(data: bytes) -> object:\\n return msgpack.unpackb(data, raw=False)\\ndef read(key):\\n value_bytes = redis_db.get(key)\\n return decompress(value_bytes)\\n# 现在我们可以恢复值对象了\\nvalue = read([121,66,3,5])\\n</code></pre>\\n<div class=\\"hljs-center\\">\\n<h4><a id=\\"_Redis__185\\"></a><strong>特定于 Redis 的优化</strong></h4>\\n</div>\n<p>为了提供快速访问和 TTL 等功能，Redis 可能需要在内存中使用数据本身所需的额外空间。接下来的两部分可帮助我们将额外开销降至最低。然后我们展示一些可以进一步帮助减少内存的概率结构。</p>\n<p><strong>从字符串或列表移动到哈希</strong></p>\\n<p>在最初的示例中，我们将许多小字符串存储为独立列表。Redis 上的每个条目都有 60 字节（没有过期）或 100 字节（有过期）的额外空间，如果我们存储数百万项（1 亿个条目 x 100 字节 = 10 GB 的开销），这将很有意义。在第一个示例中，它们存储为 Redis 列表：</p>\n<pre><code class=\\"lang-\\">"i:123.82.92.12" → [1, "John Doe", "vcp"],\\n"i:3.30.7.124" → [12, "James Smith", "pr"],\\n...\\n"i:121.66.3.5" → [5, "Peter Parker", "vv"]\\n</code></pre>\\n<p>在最终的优化中，所有字段都存储在一个哈希中：</p>\n<pre><code class=\\"lang-\\">mydata → {\\n "i:123.82.92.12" : "1, John Doe, vcp",\\n "i:3.30.7.124" : "12, James Smith, pr",\\n ...\\n "i:121.66.3.5" : "5, Peter Parker, vv"\\n}\\n</code></pre>\\n<p>这使我们可以为每个条目节省 90 字节。在前面的示例中，假定每个条目都相对较小，表示内存使用量减少了 40%。</p>\n<p><strong>转换为较小的哈希（使用压缩列表）</strong></p>\\n<p>Redis 中的哈希可以在内存中编码为哈希表或压缩列表（Redis 7 中的列表包）。使用哪个参数取决于<strong>参数组</strong>（<a href=\\"https://docs.aws.amazon.com/AmazonElastiCache/latest/red-ug/ParameterGroups.html\\" target=\\"_blank\\">https://docs.aws.amazon.com/AmazonElastiCache/latest/red-ug/ParameterGroups.html</a>）中的两个参数：</p>\\n<pre><code class=\\"lang-\\">hash-max-ziplist-value（默认为 64）\\nhash-max-ziplist-entries（默认为 512）\\n</code></pre>\\n<p>如果键的任何值超过两个配置，它将自动存储为哈希表而不是压缩列表。哈希表使用的内存量是压缩列表的两倍，但对于大哈希可能会更快。其想法是使用压缩列表，同时将每个哈希中的项数保持在合理的数字。</p>\n<p>为了在压缩列表中高效地存储项，我们将单个大哈希迁移到许多大小相似的小哈希中：</p>\n<pre><code class=\\"lang-\\">mydata:001 → {\\n i:12.82.92.12 : [1, "John Doe", "vcp"],\\n i:34.30.7.124 : [12, "James Smith", "pr"],\\n i:121.66.3.5 : [5, "Peter Parker", "vv"]\\n}\\nmydata:002 → {\\n i:1.82.92.12 : [1, "John Doe", "vcp"],\\n i:9.30.7.124 : [12, "James Smith", "pr"],\\n i:11.66.3.5 : [5, "Peter Parker", "vv"]\\n}\\n...\\nmydata:999 → {\\n i:23.82.92.12 : [1, "John Doe", "vcp"],\\n i:33.30.7.124 : [12, "James Smith", "pr"],\\n i:21.66.3.5 : [5, "Peter Parker", "vv"]\\n}\\n</code></pre>\\n<p>为了实现这种空间效率，我们使用以下代码：</p>\n<pre><code class=\\"lang-\\">import binascii\\nSHARDS = 1000 # 存储桶数，目标是每个桶少于 1000 项\\nPREFIX = "mydata:" # 用于轻松地在我们的数据库中查找数据的前缀\\n\\ndef get_shard_key(key: bytes) -> str:\\n """\\n 根据 CRC 和分片数量计算给定键的 shard_key。\\n """\\n shard_id = binascii.crc32(key) % SHARDS # 使用模数精确获得 1000 个存储桶\\n return PREFIX+str(shard_id)\\n\\ndef write(key, value):\\n shard_key = get_shard_key(key) # 分片是键的函数 \\n redis_db.hset(shard_key, key, value)\\n\\nwrite(b'i:21.66.3.5', b'1, John Doe, vcp')\\n</code></pre>\\n<p>要读回这些值，我们使用以下代码：</p>\n<pre><code class=\\"lang-\\">def read(key):\\n shard_key = get_shard_key(sample_key)\\n return redis_db.hget(shard_key, sample_key)\\n\\nvalue = read(sample_key)\\n</code></pre>\\n<p>以下屏幕截图显示了如何在 Amazon ElastiCache for Redis 控制台上编辑参数组的示例。<br />\\n<img src=\\"https://dev-media.amazoncloud.cn/defd03c2e2654dc4af9ae8d4999bd7d6_image.png\\" alt=\\"image.png\\" /><br />\\n为了确保您实际上使用的是压缩列表，您可以使用 object encoding 命令：</p>\n<pre><code class=\\"lang-\\">>>object encoding "mydata:001"\\n"ziplist"\\n>>memory usage "mydata:001"\\n(integer) 5337\\n</code></pre>\\n<p>内存使用量也应该比我们存储为哈希列表时少 40% 左右。如果您没有看到类型为压缩列表，请检查两个参数并确保两个条件都得到满足。</p>\n<p><strong>使用概率结构</strong></p>\\n<p>如果您需要计算集合中的项数，但不需要精确，**HyperLogLOG **（<a href=\\"https://redis.com/redis-best-practices/counting/hyperloglog/\\" target=\\"_blank\\">https://redis.com/redis-best-practices/counting/hyperloglog/</a>）是一种原生支持的概率数据结构，用于计算集合中的唯一项。<strong>HyperLogLog 算法</strong>（<a href=\\"https://en.wikipedia.org/wiki/HyperLogLog\\" target=\\"_blank\\">https://en.wikipedia.org/wiki/HyperLogLog</a>）能够使用 1.5 kB 的内存以 2% 的典型准确度（标准误差）估计超过 109 的基数。</p>\\n<p><strong>Bloom 筛选器</strong>（<a href=\\"https://en.wikipedia.org/wiki/Bloom_filter\\" target=\\"_blank\\">https://en.wikipedia.org/wiki/Bloom_filter</a>）也是一种高度节省空间和时间的概率数据结构。尽管原生不支持，但可以实现。Bloom 筛选器用于测试元素是否是误报概率很小（但没有误报）的集合的成员。它允许您以 1% 的误报概率存储少于 10 位的项。</p>\\n<p>如果您需要简单地检查具有最小冲突机会的等效性，您可以存储内容的哈希值。例如，您可以使用 xxHash （<a href=\\"https://github.com/Cyan4973/xxHash\\" target=\\"_blank\\">https://github.com/Cyan4973/xxHash</a>）之类的快速、非加密哈希函数：</p>\\n<pre><code class=\\"lang-\\">>>import xxhash\\n>>hashed_content = xxh32_intdigest(b'134, John William Doe, vcpvvcppvvcc')\\n>>redis_db.set("my_key",hashed_content)\\n</code></pre>\\n<p>没有办法恢复原始值（除非您把它存储在其他地方），但是我们可以使用哈希版本来检查是否存在：</p>\n<pre><code class=\\"lang-\\">>>new_content = xxh32_intdigest(b'131, Peter Doe, vcpvvcppvvcc')\\n>>if redis_db.get("my_key") == new_content:\\n>> print("No need to store")\\n</code></pre>\\n<div class=\\"hljs-center\\">\\n<h4><a id=\\"_317\\"></a><strong>数据压缩</strong></h4>\\n</div>\n<p>减少内存消耗的一种最简单的方法是减小键和值的大小。这不是 Redis 所特有的，但特别适用于它。</p>\n<p>通常，Redis（以及半结构化和结构化数据库）的压缩与文件压缩有很大不同。原因是，在 Redis 中，我们通常存储短字段。</p>\n<p><strong>长数据的压缩</strong></p>\\n<p>要压缩长数据，您可以使用常用的压缩算法，例如 Gzip、LZO 或 Snappy。在本例中，我们使用了 <strong>LZ4</strong>（<a href=\\"https://github.com/lz4/lz4\\" target=\\"_blank\\">https://github.com/lz4/lz4</a>），它在速度和压缩比之间取得了很好的平衡：</p>\\n<pre><code class=\\"lang-\\">import lz4.frame\\nfrom faker import Faker\\nfake = Faker()\\n\\ndef compress(text: str)-> bytes:\\n text_bytes = str.encode(text) # 转换为字节\\n return lz4.frame.compress(text_bytes)\\n\\ntext = fake.paragraph(nb_sentences=100) # 生成包含 100 个句子的段落\\ncompressed_bytes = compress(text)\\n</code></pre>\\n<p>要恢复原始值，我们可以简单地将压缩后的字节传递给 LZ4 库</p>\n<pre><code class=\\"lang-\\">def decompress(data: bytes) -> str:\\n return lz4.frame.decompress(data)\\n\\noriginal = decompress(compressed_bytes)\\n</code></pre>\\n<p>在本例中，压缩后的字符串比压缩前小 20%。请注意，对于小字符串（通常存储在数据库中），这不太可能产生好的结果。如果您的数据非常大，您可以考虑将其存储在其他地方，例如 **Amazon Simple Storage Service **(Amazon S3)（<a href=\\"https://aws.amazon.com/cn/s3/\\" target=\\"_blank\\">https://aws.amazon.com/cn/s3/</a>）。</p>\\n<p>如前所述，对于小字符串（在 Redis 中更为常见），这不会产生好的结果。我们可以尝试压缩值组（例如值分片），但这会增加代码的复杂性，因此接下来的选项更有可能对我们有所帮助。</p>\n<h4><a id=\\"_362\\"></a><strong>自定义基础编码</strong></h4>\\n<p>减少所用空间的一种方法是使用特定数据类型的有限字符范围。例如，我们的应用程序可能会强制要求用户名只能包含小写字母 (a-z) 和数字 (0-9)。如果是这样的话，**base36 **（<a href=\\"https://en.wikipedia.org/wiki/Base36\\" target=\\"_blank\\">https://en.wikipedia.org/wiki/Base36</a>）编码比简单地将它们存储为字符串更有效。</p>\\n<p>您也可以根据自己的字母创建自己的基础。在本例中，我们假设正在记录石头剪刀布游戏玩家的所有动作。为了有效地对其进行编码，我们将每个动作存储为单个字符串。在我们的示例中，我们将石头表示为 0，将布表示为 1，剪刀表示为 2。然后，我们可以通过将其存储为使用所有潜在值的整数来进一步压缩它：</p>\n<pre><code class=\\"lang-\\">>>BASE=3\\n>>ALPHABET="012"\\n>>player_moves=b"20110012200120000110" # 0 是石头，1 是布，2 是剪刀\\n>>compressed=int(player_moves, BASE) # 转换为 base-3 数字\\n2499732264\\n</code></pre>\\n<p>虽然原始 player_moves 字符串需要 20 字节，但压缩后的整数可以存储在 4 字节中（减少 75% 的空间）。解压缩稍微复杂一些：</p>\n<pre><code class=\\"lang-\\">def decompress(s) -> str:\\n res = ""\\n while s:\\n res+=ALPHABET[s%BASE]\\n s//= BASE\\n return res[::-1] or "0"\\n\\ndecompress(2499732264) # 这将返回“20110012200120000110”\\n</code></pre>\\n<p>使用 base-36 可以减少约 64% 的使用空间。有一些<strong>常用的编码</strong>（<a href=\\"https://en.wikipedia.org/wiki/Binary-to-text_encoding\\" target=\\"_blank\\">https://en.wikipedia.org/wiki/Binary-to-text_encoding</a>）和一些<strong>易于使用的库</strong>（<a href=\\"https://www.npmjs.com/package/base-x\\" target=\\"_blank\\">https://www.npmjs.com/package/base-x</a>）。</p>\\n<p>**<br />\\n使用域字典压缩短字符串**</p>\n<p>大多数压缩算法（例如 Gzip、LZ4、Snappy）在压缩小字符串（例如人名或 URL）方面效果不佳。这是因为他们在压缩数据的同时了解数据。</p>\n<p>一种有效的技巧是使用<strong>预训练的字典</strong>（<a href=\\"https://pyzstd.readthedocs.io/en/latest/#dictionary\\" target=\\"_blank\\">https://pyzstd.readthedocs.io/en/latest/#dictionary</a>）。在以下示例中，我们使用 Zstandard 来训练用于压缩和解压缩作业名称的字典：</p>\\n<pre><code class=\\"lang-\\">import pyzstd \\nfrom faker import Faker\\nfake = Faker()\\nFaker.seed(0)\\n\\ndef data() -> list:\\n samples = []\\n for i in range(1024): # 使用 1000+ 个作业进行训练\\n tmp_bytes = str.encode(fake.job())\\n samples.append(tmp_bytes)\\n return samples\\n\\njob_dictionary = pyzstd.train_dict(data(), 100*1024)\\n</code></pre>\\n<p>拥有 job_dictionary 后，压缩任何随机作业都很简单：</p>\n<pre><code class=\\"lang-\\">def compress(job_string) -> bytes:\\n return pyzstd.compress(job_string, 10, job_dictionary)\\n\\ncompressed_job = compress(b'Armed forces technical officer') # 我们可以压缩任何作业\\n</code></pre>\\n<p>解压缩也很简单，但需要原始字典：</p>\n<pre><code class=\\"lang-\\">uncompressed_job = pyzstd.decompress(compressed_job, job_dictionary)\\n</code></pre>\\n<p>在这个简单的示例中，最初的未压缩作业是 30 字节，而压缩后的作业是 21 字节（节省了 30% 的空间）。</p>\n<p><strong>适用于短字段的其他编码技术</strong></p>\\n<p>短字符串压缩在文件压缩中很常见，但您可以根据用例使用其他方法。您可以从 <strong>Amazon Redshift 压缩编码</strong>中获得灵感：</p>\\n<p>Byte-dictionary — 如果数据的基数很小，则可以为符号而不是完整字符串编码索引。这方面的一个示例是客户所在的国家/地区。由于国家/地区数量较少，因此您可以通过仅存储国家/地区的索引来节省大量空间。</p>\n<p>Delta — 购买时间之类的内容可能会按差异使用完整时间戳进行存储，差异会更小。</p>\n<p>Mostly — 当列的数据类型大于大多数存储值所需的值时，Mostly 编码很有用。</p>\n<p>Run length — Run length 编码将连续重复的值替换为由该值和连续出现次数（运行长度）组成的标记。</p>\n<p>Text255 和 text32k — Text255 和 text32k 编码对于压缩经常出现相同单词的字符串字段非常有用。</p>\n<p>通常，短字符串压缩受益于结构信息约束（例如，IPv4 由 0-255 之间的四个数字组成）和分发信息（例如，许多使用者电子邮件都有一个免费域，如 gmail.com、yahoo.com 或 hotmail.com）。<br />\\nAmazon Redshift：</p>\n<p><a href=\\"https://aws.amazon.com/cn/redshift/\\" target=\\"_blank\\">https://aws.amazon.com/cn/redshift/</a></p>\\n<p>压缩编码：</p>\n<p><a href=\\"https://docs.aws.amazon.com/redshift/latest/dg/c_Compression_encodings.html\\" target=\\"_blank\\">https://docs.aws.amazon.com/redshift/latest/dg/c_Compression_encodings.html</a></p>\\n<p>Byte-dictionary：</p>\n<p><a href=\\"https://docs.aws.amazon.com/redshift/latest/dg/c_Byte_dictionary_encoding.html\\" target=\\"_blank\\">https://docs.aws.amazon.com/redshift/latest/dg/c_Byte_dictionary_encoding.html</a></p>\\n<p>Delta：</p>\n<p><a href=\\"https://docs.aws.amazon.com/redshift/latest/dg/c_Delta_encoding.html\\" target=\\"_blank\\">https://docs.aws.amazon.com/redshift/latest/dg/c_Delta_encoding.html</a></p>\\n<p>Mostly：</p>\n<p><a href=\\"https://docs.aws.amazon.com/redshift/latest/dg/c_MostlyN_encoding.html\\" target=\\"_blank\\">https://docs.aws.amazon.com/redshift/latest/dg/c_Delta_encoding.html</a></p>\\n<p>Run length：</p>\n<p><a href=\\"https://docs.aws.amazon.com/redshift/latest/dg/c_Runlength_encoding.html\\" target=\\"_blank\\">https://docs.aws.amazon.com/redshift/latest/dg/c_Delta_encoding.html</a></p>\\n<p>Text255 和 text32k：</p>\n<p><a href=\\"https://docs.aws.amazon.com/redshift/latest/dg/c_Text255_encoding.html\\" target=\\"_blank\\">https://docs.aws.amazon.com/redshift/latest/dg/c_Text255_encoding.html</a></p>\\n<div class=\\"hljs-center\\">\\n<h4><a id=\\"_479\\"></a><strong>决策表</strong></h4>\\n</div>\n<p>下表列出了应用每种技术的摘要和必要要求。<br />\\n<img src=\\"https://dev-media.amazoncloud.cn/a5a23793185f49b7bf0ef7519d6a877f_image.png\\" alt=\\"image.png\\" /></p>\n<div class=\\"hljs-center\\">\\n<h4><a id=\\"_490\\"></a><strong>结论</strong></h4>\\n</div>\n<p>在这篇博文中，我向您展示了优化 Redis 实例内存消耗的多种方法。这可能会对成本和性能产生积极影响。任何优化都会在用于读写的空间和时间之间进行权衡。根据数据的存储方式，可能会丢失一些原生 Redis 功能（例如驱逐策略）。Redis 也提供了一个很好的内存优化指南（<a href=\\"https://docs.redis.com/latest/ri/memory-optimizations/\\" target=\\"_blank\\">https://docs.redis.com/latest/ri/memory-optimizations/</a>），与这篇博文有些重叠。</p>\\n<p>您如何有效地将数据存储在与 Redis 兼容的数据库中？请在评论部分告诉我。</p>\n<p><strong>本篇作者</strong></p>\\n<p>Roger Sindreu</p>\n<p>Amazon Web Services 的解决方案构架师。他是一名数据库工程师，在过去的 20 年中一直领导工程团队。他的兴趣是 AI/ML、数据库、FSI 以及与 亚马逊云科技相关的一切。</p>\n<p><a href=\\"https://aws.amazon.com/cn/blogs/china/optimize-application-memory-usage-on-amazon-elasticache-for-redis-and-amazon-memorydb-for-redis/\\" target=\\"_blank\\">阅读原文</a></p>\n"}
Amazon MemoryDB for Redis 和 Amazon ElastiCache for Redis 的内存优化
亚马逊云科技
Amazon MemoryDB for Redis
0
0
亚马逊云科技解决方案 基于行业客户应用场景及技术领域的解决方案
联系亚马逊云科技专家
亚马逊云科技解决方案
基于行业客户应用场景及技术领域的解决方案
联系专家
0
目录
分享
点赞
收藏
目录立即注册，开启您的免费套餐
立即关注
亚马逊云开发者
公众号
User Group
公众号
亚马逊云科技
官方小程序
“AWS” 是 “Amazon Web Services” 的缩写，在此网站不作为商标展示。
立即关注
亚马逊云开发者
公众号
User Group
公众号
亚马逊云科技
官方小程序
“AWS” 是 “Amazon Web Services” 的缩写，在此网站不作为商标展示。
关于我们 
更多资源
开发者工具
更多支持
立即关注
亚马逊云开发者
公众号
User Group
公众号
亚马逊云科技
官方小程序
“AWS” 是 “Amazon Web Services” 的缩写，在此网站不作为商标展示。
