暂无图片
暂无图片
暂无图片
暂无图片
暂无图片

RisingWave 产品月报|25 年 3 月

Doc 团队
来源|RisingWave 官网

欢迎阅读 RisingWave 2025 年 3 月产品月报!本期内容将为您带来过去一个月的产品更新、文档优化、博客发布动态,以及即将上线的精彩活动,敬请关注!


产品更新

RisingWave Cloud

  • 网络指标(Network Metrics)RisingWave 现在支持通过指标仪表板更精细地监控网络流量。此改进更容易发现异常的 Internet 和 PrivateLink 流量,帮助控制网络成本。

    网络指标仪表盘|图源:RW
  • 密钥管理(Secret Management)密钥管理是 RisingWave SQL 中用于保护外部连接和防止凭据泄露的关键功能。此前仅能通过 SQL 使用的密钥管理功能,现在也可在 Cloud Portal UI 中访问,让您轻松创建和管理密钥。

    密钥管理|图源:RW
  • 用户管理(Users Management)RisingWave Cloud 现在提供“用户”页面,您可以在表格视图中查看所有用户及其数据库权限。出于安全考虑,用户密码仅在创建时可见。设置后,密码无法检索——如果丢失访问权限,您需要重置密码。

RisingWave 内核
  • Sink 速率限制:RisingWave 现在支持 Sink 速率限制[1],以防止因吞吐量激增导致下游系统过载。通过使用 ALTER SINK ... SET SINK_RATE_LIMIT,用户可以限制吞吐量,实现更平稳的数据流动和更好的系统稳定性。这有助于在存储和消息传递集成中保持可靠的性能。细节请参阅 PR #19660RisingWave[2]

Sink 速率限制|图源:RW
  • 视图权限管理RisingWave 现在支持管理员修改用户对特定视图的访问权限,确保更好地控制数据可见性和安全性。此外,权限检查通过确保只有授权用户才能访问或修改视图来增强系统安全性。这是帮助高级用户实现行级安全性的基础。具体实现细节,请参阅文档[3]


文档更新

  • 了解如何使用 generate_series()
    处理时间窗口中的间隙[4]
  • RisingWave 支持在流式和临时模式下的跨数据库查询。有关更多实现细节和用法,请参阅跨数据库查询[5]
  • 除了 S3,您还可以使用表函数 file_scan()
     读取存储在 GCS[6] 和 Azure Blob[7] 中的 Parquet 文件。
  • RisingWave 为计算节点 CPU 数不超过四核的集群提供付费功能试用,让用户可以在小规模环境下评估这些功能。具体实现细节,请参阅 RisingWave Premium 文档[8]
精选文章

    文章 1:Streaming As-Of Joins[9]

    在许多实时应用场景中,如金融交易、风险分析以及物联网监控,不同数据源中的时间戳往往无法完全对齐。为了高效处理这些数据流,我们通常需要按照最接近的时间戳进行关联操作。

    这正是 As-Of Join 发挥作用的地方。RisingWave 是少数支持 流式 As-Of Join 的流处理数据库之一。大多数传统数据库仅支持 批处理 As-Of Join,虽然适用于历史数据分析,但在实时场景中响应速度往往无法满足需求。

    本文介绍了为何流式 As-Of Join 至关重要、RisingWave 中的具体实现机制,以及如何在实际项目中高效使用这一特性。

    文章 2:Time Travel Queries[10]

    在传统数据库中,访问历史数据通常需要依赖快照、手动版本管理或审计日志等方式。而在 RisingWave 中,用户可以通过内建的时光旅行查询(Time Travel Query) 功能,直接访问某张表在过去某一时刻的状态。

    这一特性在调试、合规审计、数据取证及回溯分析等场景中尤为实用。

    本文深入讲解了 RisingWave 中时光旅行查询的工作机制、启用方式,并展示若干真实场景下的应用示例。

    精彩活动

    • Real-Time Data+AI night[11]
    • Iceberg 峰会 2025[12]

    参考资料
    [1] 

    Sink 速率限制: https://docs.risingwave.com/sql/commands/sql-alter-sink

    [2] 

    PR #19660: https://github.com/risingwavelabs/risingwave/pull/19660

    [3] 

    文档: https://docs.risingwave.com/sql/commands/sql-revoke

    [4] 

    处理时间窗口中的间隙: https://docs.risingwave.com/processing/sql/time-windows

    [5] 

    跨数据库查询: https://docs.risingwave.com/processing/overview

    [6] 

    GCS: https://docs.risingwave.com/integrations/sources/google-cloud-storage

    [7] 

    Azure Blob: https://docs.risingwave.com/integrations/sources/azure-blob

    [8] 

    RisingWave Premium 文档: https://docs.risingwave.com/get-started/rw-premium-edition-intro#free-trial

    [9] 

    Streaming As-Of Joins in RisingWave: https://www.risingwave.com/blog/streaming-as-of-joins-in-risingwave-real-time-event-matching-for-time-series-data/

    [10] 

    Time Travel Queries in RisingWavehttps://docs.risingwave.com/get-started/rw-premium-edition-intro#free-trial

    [11] 

    Real-Time Data+AI night: https://lu.ma/7vl2dnb2

    [12] 

    Iceberg 峰会 2025: https://www.icebergsummit2025.com/

    关于 RisingWave 

    RisingWave 是一款基于 Apache 2.0 协议开源的分布式流数据库,致力于为用户提供极致简单、高效的流数据处理与管理能力。RisingWave 采用存算分离架构,实现了高效的复杂查询、瞬时动态扩缩容以及快速故障恢复,并助力用户极大地简化流计算架构,轻松搭建稳定且高效的流计算应用。
    RisingWave 始终聆听来自社区的声音,并积极回应用户的反馈。目前,RisingWave 已汇聚了 150+ 名开源贡献者和 3000+ 名社区成员。全球范围内,已有上百个 RisingWave 集群在生产环境中部署。

    技术内幕

    如何上手 RisingWave 👉 新手入门教程

    RisingWave 中文用户文档上线,阅读更高效!

    深入探索 RisingWave 中的高可用性与容错机制

    深入理解 RisingWave 流处理引擎(三):触发机制

    深入理解 RisingWave 流处理引擎(二):计算模型

    深入理解 RisingWave 流处理引擎(一):总览

    用户案例
    视源股份(CVTE)IT 流计算应用历程
    尘锋 SCRM 如何使用 RisingWave 实时打宽
    RisingWave 在超百亿管理规模对冲基金公司中的应用
    金融科技公司 Kaito 使用 RisingWave 实现实时智能化
    龙腾出行如何通过 RisingWave 实现实时数据分析

    RisingWave 助力乾象投资打造实时监控平台



    👇 点击阅读原文立即体验 RisingWave

    文章转载自RisingWave中文开源社区,如果涉嫌侵权,请发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。

    评论