FriendFeed如何用MySQL储存K-V数据

@这是一篇比较老的文章,我现在的理解是使用MySQL实现了一个MongoDB,在思路上有借鉴意义。

原文地址: http://backchannel.org/blog/friendfeed-schemaless-mysql

背景

我们使用MySQL储存FriendFeed所有的数据。我们的数据库随着我们的用户基数增长而增长了许多,现在存储了超过2亿5千万(250 million)条目和数据串,这些数据来自评论和朋友列表的“喜欢”。

伴随着数据的增长,我们反复处理因为数据过快增长而带来的扩展问题。我们曾经使用了常规方法,比如使用从属读服务器和memcache,增加读取能力;使用数据库分片来提高写入的能力。然而,随着我们的发展,发现增加新功能比扩展现有系统容量更困难。

尤其在这些情况下:设计模式改变;给一个超过一两千万行的数据库增加索引,数据库一次完全锁死几小时。删除旧索引也会占用同样的时间,并且不删除他们会损害性能。因为数据库会在每次INSERT插入操作时,继续读写这些不使用的块,并把重要的块挤出内存。存在避开这些问题的非常复杂的设计,比如在从服务器上生成索引,然后对调主从服务器。但是这些方法容易出错,太过重量级,并且暗中阻止我们添加需要改变索引或设计模式的新功能。自从我们的数据库深度分片开始,与MySQL相关的功能,比如JOIN对于我们毫无价值。所以,我们决定在关系型数据库之外寻找答案。

为了使用灵活模式和快速索引特性存储数据,诞生了许多项目,比如说CouchDB。然而,似乎他们中没有一个拥有足够的信任被大型网站广泛使用。在测试中,我们运行表明,对于我们的需求,他们中没有一款足够稳定或经受考验。MySQL可以满足需求,并且从来不会损坏数据,或重复工作。我们已经认识到了它的局限性。我们喜欢MySQL用来存储,而不是关系型数据库的使用模式。

在一些考虑之后,我们决定在MySQL之上,实现一套“无模式”的存储系统,而不是完整的使用其他新型存储系统。这篇文字试图在高层次上描述系统的细节。我们很好奇其他大型网站是如何解决这个问题的,并且我们认为一些我们做的设计工作可能会对其他开发者有所帮助。

概述

我们的数据库存储无模式的属性包(比如JSON或Python中的字典)。存储实体唯一需要的属性是id,一个16字节的UUID(通用唯一标识符)。实体的其他属性在数据库连接之前是不透明的。我们可以简单地通过存储新属性来改变模式。

我们通过在单独的MySQL表中存储索引,来索引这些实体的数据。如果我们想在每个实体中索引3个属性,我们将会有3个MySQL表(每一个对应一个索引)。如果我们想要停止使用一个索引,先从代码停止向这张表写入,然后根据需要在MySQL中删除这张表。如果我们想使用一个新索引,先在MySQL中为这个索引建立新表,然后运行一个程序异步填入索引,这样不会干扰我们的正常服务。

因此,相对之前我们后来会有更多的表,但是添加和删除索引非常容易。我们拥有深度优化过的程序用来填充新索引(被我们叫做”Cleaner”),因此可以在不干扰网站正常服务的情况下迅速填充索引。我们可以在一天的时间内存储新属性并建立索引,而不是一个周的时间。并且,我们不需要再交换MySQL主从服务器,或做其他提心吊胆的操作工作让其实现。

详情

在MySQL中,我们的实体像这样被存储在表中:

CREATE TABLE entities (
    added_id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
    id BINARY(16) NOT NULL,
    updated TIMESTAMP NOT NULL,
    body MEDIUMBLOB,
    UNIQUE KEY (id),
    KEY (updated)
) ENGINE=InnoDB;

added_id列存在,因为InnoDB存储数据行完全按照主键顺序。自增主键确保新实体在旧实体之后连续地被写入磁盘,同时帮助读写操作确定位置(因为FriendFeed页面按照年代反转排序,所以新实体相对于旧实体,倾向于拥有更频繁的读取)。实体内容被使用zlib算法压缩存储,pickle化的python字典。

索引存储在分开的单独表里。为了创建一个新索引,要新建一个表,存储我们想要索引的属性,以便在所有数据库群中查找。例如,一个标准FriendFeed实体像这样:

{
    "id": "71f0c4d2291844cca2df6f486e96e37c",
    "user_id": "f48b0440ca0c4f66991c4d5f6a078eaf",
    "feed_id": "f48b0440ca0c4f66991c4d5f6a078eaf",
    "title": "We just launched a new backend system for FriendFeed!",
    "link": "http://friendfeed.com/e/71f0c4d2-2918-44cc-a2df-6f486e96e37c",
    "published": 1235697046,
    "updated": 1235697046,
}

我们想索引实体属性中的user_id,以便可以渲染给定用户请求的一个页面内所有实体。索引表像这样:

CREATE TABLE index_user_id (
    user_id BINARY(16) NOT NULL,
    entity_id BINARY(16) NOT NULL UNIQUE,
    PRIMARY KEY (user_id, entity_id)
) ENGINE=InnoDB;

我们数据存储代替你自动维护索引,因此开启一个数据存储的实例 ,存储给定索引上文结构的实体应该这样写(python):

user_id_index = friendfeed.datastore.Index(
    table="index_user_id", properties=["user_id"], shard_on="user_id")datastore = friendfeed.datastore.DataStore(
    mysql_shards=["127.0.0.1:3306", "127.0.0.1:3307"],
    indexes=[user_id_index])new_entity = {
    "id": binascii.a2b_hex("71f0c4d2291844cca2df6f486e96e37c"),
    "user_id": binascii.a2b_hex("f48b0440ca0c4f66991c4d5f6a078eaf"),
    "feed_id": binascii.a2b_hex("f48b0440ca0c4f66991c4d5f6a078eaf"),
    "title": u"We just launched a new backend system for FriendFeed!",
    "link": u"http://friendfeed.com/e/71f0c4d2-2918-44cc-a2df-6f486e96e37c",
    "published": 1235697046,
    "updated": 1235697046,}
 datastore.put(new_entity)
 entity = datastore.get(binascii.a2b_hex("71f0c4d2291844cca2df6f486e96e37c"))
 entity = user_id_index.get_all(datastore, user_id=binascii.a2b_hex("f48b0440ca0c4f66991c4d5f6a078eaf"))

上文的索引类在素有实体中寻找user_id属性,并自动在index_user_id表中维护索引。自从我们的数据库分片以后,shard_on属性就被用来确认,索引被存储在哪一个数据库片上(在这个案例中,值为实体的ueser_id对分片数量取余)。

你可以使用索引实例查询一个索引(请参考上文user_id_index.get_all)。数据存储系统代码会在python中完成index_user_id表和实体表之间的“join”工作,通过先在所有数据库片中查询index_user_id表,拿到实体ID的列表,然后再实体表中读取这些ID。

为了添加一个新索引,例如,在link属性上建立所有,我们应该创建一个新表:

CREATE TABLE index_link (
    link VARCHAR(735) NOT NULL,
    entity_id BINARY(16) NOT NULL UNIQUE,
    PRIMARY KEY (link, entity_id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

我们将会改变存储系统的初始代码来增加这个新索引:

user_id_index = friendfeed.datastore.Index(table="index_user_id", properties=["user_id"], shard_on="user_id")

link_index = friendfeed.datastore.Index(table="index_link", properties=["link"], shard_on="link")

datastore = friendfeed.datastore.DataStore(
    mysql_shards=["127.0.0.1:3306", "127.0.0.1:3307"],
    indexes=[user_id_index, link_index])

并且我们可以异步填充这个索引(即使在服务繁忙的时候),使用:

./rundatastorecleaner.py --index=index_link

一致性与原子性

自从我们的数据库开始分片,对比实体数据本身,一个实体的索引会被存储到不同数据库片上,一致性是一个问题。假设程序在写完所有索引表前崩溃将会怎样呢?

建立一个事务协议对于大部分有抱负的FriendFeed工程师是一个诱人的方案,但是我们希望保持系统尽可能的简单。我们决定这样放开约束:

  • 属性包存储在主实体表中作为标准规范
  • 索引可能不会反映实体的真实值

因此,我们用以下步骤向数据库写入了新的实体:

  1. 使用InnoDB的ACID属性,向实体表写入实体
  2. 向所有数据库片上的所有索引表,写入索引

当从索引表读取时,我们知道结果不是非常精确的(也就是,如果写入时没有完成步骤2,索引可能反映旧的属性值)。为了保证基于以上约束,我们不会返回无效的实体,我们使用索引表来确认要读取哪一个实体,但是我们会在实体中重复提交过滤查询,而不是相信索引的完整性:

  1. 基于查询在所有索引表中读取entity_id
  2. 根据给定的实体ID在实体表中读取实体
  3. 过滤(in python)所有不与实际属性值匹配的实体

为了确保索引不失去持久性,不一致最后会被修复,我上文提到过的“Cleaner”程序,在表间不断运行,写入丢失索引并清除旧的、无效的索引。它会先处理最近更新的实体,所以在实际中索引中的不一致会被非常快的修复(在几秒之内)。

性能

我们在新系统中已经对主要索引进行了非常多的优化,并且对优化结果非常满意。下面是上个月FriendFeed页面延迟的图表(我们在几天前启动了新后台,你可以看到戏剧性的下降):

尤其是,我们系统的延迟现在非常稳定,即使在高峰的正午时间。下面是过去24小时FriendFeed页面延迟的图表:

对比一周前的数据:

到目前为止,系统真的容易完成了工作。自从我们发展了系统,已经改变了索引好多次,并且我们开始使用新模式转换最大的的MySQL表,以便于我们可以随着发展更自由的改变数据结构。

时间: 2024-10-14 20:24:44

FriendFeed如何用MySQL储存K-V数据的相关文章

consul 配置---K/V存储及ACL

consul 配置-K/V存储及ACL 标签(空格分隔): consul Consul简介 安装及运行 K/V存储 Java案例(基于Spring boot) ACL配置 小结 1.Consul简介 1.1 consul的作用 服务发现 Consul clients提供服务(例如API) 其他的client发现服务的提供者(通过DNS或http,应用可以轻松的发现他们所依赖的服务) 健康检查 Key-Value存储操作 动态配置 leader选举 feature flagging coordin

【百度地图API】交你如何用百度地图搜索自己的数据!不需数据库!

原文:[百度地图API]交你如何用百度地图搜索自己的数据!不需数据库! 摘要: 我有一定的房产数据,还有银行数据.我想在百度地图上标注出来,并且能搜索到我这些数据. 可是百度的数据库上并没有我的数据.我应该怎么办呢? ------------------------------------------------------------------------------------------ 一.无需数据库,如何建立自己的地理信息表. 如果让初学者去建立数据库,那么意味着大家还要学习数据库,

C#泛型集合之Dictionary<k, v>使用技巧

1.要使用Dictionary集合,需要导入C#泛型命名空间 System.Collections.Generic(程序集:mscorlib) 2.描述 1).从一组键(Key)到一组值(Value)的映射,每一个添加项都是由一个值及其相关连的键组成 2).任何键都必须是唯一的 3).键不能为空引用null(VB中的Nothing),若值为引用类型,则可以为空值 4).Key和Value可以是任何类型(string,int,custom class 等) 3.创建及初始化 Dictionary<

android 股票数据通过日K获取周K的数据 算法 源码

目前的数据是从新浪接口获取的, http://biz.finance.sina.com.cn/stock/flash_hq/kline_data.php?symbol=sh600000&end_date=20141120&begin_date=20120101 返回数据为XML格式: 1 <?xml version="1.0" encoding="UTF-8"?> 2 <control> 3 <content d=&qu

Linux下面的mysql的bin-log恢复数据

转自:http://blog.sina.com.cn/s/blog_13dd6daa80102wbht.html 一.开启binlog日志: 编辑打开mysql配置文件my.cnf,在[mysqld]区块设置/添加 log-bin=mysql-bin  确认是打开状态(值 mysql-bin 是日志的基本名或前缀名),重启mysqld服务使配置生效.日志刷新命令:mysql> flush logs. 二.也可登录mysql服务器,通过mysql的变量配置表,查看二进制日志是否已开启 mysql>

Java集合源码分析(七)HashMap&lt;K, V&gt;

一.HashMap概述 HashMap基于哈希表的 Map 接口的实现.此实现提供所有可选的映射操作,并允许使用 null 值和 null 键.(除了不同步和允许使用 null 之外,HashMap 类与 Hashtable 大致相同.)此类不保证映射的顺序,特别是它不保证该顺序恒久不变. 值得注意的是HashMap不是线程安全的,如果想要线程安全的HashMap,可以通过Collections类的静态方法synchronizedMap获得线程安全的HashMap. Map map = Coll

03集合:List&lt;T&gt;,Dictionary&lt;K,V&gt;

List<T>泛型集合 List<T>是C#中一种快捷.易于使用的泛型集合类型,使用泛型编程为编写面向对象程序增加了极大的效率和灵活性. 1.List<T>用法 (1)创建一个List<T>泛型集合对象实例 List<T> list = new List<T>();// T 为列表中元素的类型 List<string> mlist = new List<string>();//创建了一个 string 类型的集

C#泛型集合—Dictionary&lt;K,V&gt;使用技巧

[csharp] view plaincopy 1.要使用Dictionary集合,需要导入C#泛型命名空间 System.Collections.Generic(程序集:mscorlib) 2.描述  1).从一组键(Key)到一组值(Value)的映射,每一个添加项都是由一个值及其相关连的键组成  2).任何键都必须是唯一的  3).键不能为空引用null(VB中的Nothing),若值为引用类型,则可以为空值  4).Key和Value可以是任何类型(string,int,custom c

Cocos2d-x3.0模版容器详解之——cocos2d::Vector&lt;T&gt;, cocos2d::Map&lt;K,V&gt;, cocos2d::Value

Cocos2d-x3.0模版容器详解之一:cocos2d::Vector<T>  http://www.cocoachina.com/bbs/read.php?tid=199793Cocos2d-x3.0模版容器详解之二:cocos2d::Map<K,V>  http://www.cocoachina.com/bbs/read.php?tid=199916Cocos2d-x3.0模版容器详解之三:cocos2d::Value  http://www.cocoachina.com/b