触发器和函数示例

如何使用触发器和函数

Redis 开源 Redis Enterprise 软件 Redis 云 Redis 开源 Redis Enterprise for Kubernetes 客户端

Redis Stack 的触发器和函数功能能够检测数据发生的更改，并保证在数据源无缝执行业务逻辑。这确保了可以操作数据的新选项，并可以同时为所有客户端提供，同时简化了部署和维护。让我们探索一些特定行业的用例，这些功能在其中大放异彩。

  • 零售：在零售业，可以开发一个函数来在收到订单后立即更新库存。这使企业能够准确预测任何给定日期特定仓库的库存需求。
  • 旅游：对于旅游业，可以利用触发器来检测新的航班预订，并将相关信息有效地加载到不同消费者的队列中。然后，服务可以利用这些数据来提供有关酒店、餐厅、汽车租赁服务等的建议。利用 Redis 几何图形，强大的推荐系统可以提供本地化和个性化的建议。
  • 订阅服务：在订阅服务领域，使用 keyspace 触发器可以自动识别订阅已续订的用户，从而无缝地将其状态更改为活动状态。可以对这些用户执行进一步的操作，例如将他们添加到队列中以传递通知或执行其他操作。

这些示例突出了触发器和函数在不同行业中的实际应用，展示了它们在简化流程和提供有效解决方案方面的价值。

使用 keyspace 和 Stream 触发器来捕获事件并执行所需的 JavaScript 函数只需几行代码，即可使用新行为丰富应用程序。以下示例显示了如何使用 JavaScript 解决典型问题。

审计和日志记录

Redis 触发器可用于检测对特定数据结构的更改，并在 Redis 日志中记录审计跟踪。最新更改的时间戳可以在同一函数中更新。

function alertUserChanged(client, data) {
    // detect the event and log an audit trail
    if (data.event == 'hset'){
        redis.log('User data changed: ' + data.key);
    }
    else if (data.event == 'del'){
        redis.log('User deleted: ' + data.key);
    }

    var curr_time = client.call("time")[0];

    // add the current timestamp to the Hash
    client.call('hset', data.key, 'last', curr_time);
}

redis.registerKeySpaceTrigger('alert_user_changed', 'user:', 
    alertUserChanged, {description: 'Report user data change.'});

丰富和转换数据

可以提取、丰富或转换数据，然后再次加载。 例如，在将文档插入 Hash 数据结构时，触发器可以启动函数的执行，该函数计算文本中的单词数（在示例中，提供了一个简单的标记化，但逻辑可以根据需要复杂）。 计数器最终与原始文档一起存储在同一 Hash 中。

function wordsCounter(client, data){
    text = client.call('hget', data.key, 'content');
    words = text.split(' ').length;
    client.call('hset', data.key, 'cnt', words.toString());
    redis.log('Number of words: ' + words.toString()); //This log is for demo purposes, be aware of spamming the log file in production
}

redis.registerKeySpaceTrigger('words_counter', 'doc:', 
    wordsCounter, {description: 'Count words in a document.'});

批量操作

JavaScript 函数可以根据需要执行，例如作为计划或定期维护例程的一部分。 一个例子可以是删除由所需模式标识的数据。

#!js api_version=1.0 name=utils


redis.registerAsyncFunction('del_keys', async function(async_client, pattern){
    var count = 0;
    var cursor = '0';
    do {
        async_client.block((client)=>{
            var res = client.call('scan', cursor, 'match', pattern);
            cursor = res[0];
            var keys = res[1];
            keys.forEach((key) => {
                client.call('del', key);
            });
        });
    } while(cursor != '0');
    return count;
});

函数 del_keys 对数据库中与所需模式匹配的所有键执行异步批量扫描，并进入阻塞部分，在其中获取部分结果。 此函数的异步设计允许非阻塞执行，因此其他客户端在任意大小的键空间上执行迭代时不会饿死。 该函数可以按如下方式调用。

TFCALLASYNC utils.del_keys 0 "user:*"

自动过期

有时，强制执行本质上生命周期较短的数据的到期时间非常有用。 一个例子可以是会话数据或身份验证令牌。 触发器适合用例，可以执行一个设置所需 TTL 的函数。

function automaticSessionExpiry(client, data){
    client.call('expire', data.key, '3600');
    redis.log('Session ' + data.key + ' has been automatically expired'); //This log is for demo purposes, be aware of spamming the log file in production
}

redis.registerKeySpaceTrigger('automaticSessionExpiry', 'session:', 
    automaticSessionExpiry, {description: 'Set the session TTL to one hour.'});
评价此页
返回顶部 ↑