每15分钟刷新一次Azure Redis缓存

Question

我需要每15分钟将数据从MySQL数据库同步到Redis，以便缓存为最新数据。

我正在使用ubuntu托管(Node.js) webservcies。因此，每当调用rest时，它都需要从缓存中获取数据并提供数据。

那么，现在我需要编写一个后台作业来将MySQL数据同步到缓存内存。

如果需要编写后台作业，可以使用node.js编写并同步它，并使用crontab命令作为后台作业在Ubuntu中运行。

Answer 1

是。您可以编写一个nodejs脚本并通过crontab命令运行它来将数据从MySQL同步到Redis。

根据我的经验，您需要下面的一些nodejs包来帮助实现这些需求。

NodeJS ORM for MySQL：

• 后缀：http://docs.sequelizejs.com/en/latest/ (npm安装后缀mysql)

NodeJS的Redis客户端：

• https://github.com/luin/ioredis (npm安装ioredis)
• node_redis：redis (npm安装redis)

示例代码~/sync-mysql-redis.js

// Create a mysql client connection
var Sequelize = require('sequelize');
var sequelize = new Sequelize('mysql://user:pass@azure_mysql_host:3306/dbname');
// Create a redis client using node_redis
var redis = require("redis");
var client = redis.createClient(6379, '<redis_host>');
// Query entities data from MySQL table
sequelize.query("SELECT * FROM `t_entity`", { type: sequelize.QueryTypes.SELECT})
  .then(function(entities) {
    for(var entity in entites) { // for-each entity from entites list
        var hash_key = entity.Id // for example, get the entity id as redis hash
        for(var prop in entity) { // for-each property from entity
            client.hset([hash_key, prop, entity[prop]], redis.print); // mapping a mysql table record to a redis hash
        }
    }
  });

对于crontab配置，您需要使用vim /etc/crontab作为root用户或sudo用户：

$ sudo vim /etc/crontab
# Add a crontab record to run nodejs script interval 15 mins
*/15 * * * * node \home\user\sync-mysql-redis.js