
如果驱动您业务运行的事件——无论是零售银行的交易清算、销售点的刷卡操作,还是全球供应链的货物流动,甚至是 Oracle 系统内的数据变更——都能立即推动智能决策,会怎样?借助 Snowflake Openflow Connector for Oracle 数据库,这些事件不再局限于运营系统,而可以安全流入 Snowflake。通过由 Snowflake Cortex Agents 提供技术支持的 Snowflake Intelligence(二者目前均可公开预览),企业能够将这些数据与其他信号结合分析,实现实时推理、决策和自动执行。对于依赖 Oracle 的行业,如银行、零售、生命科学和医疗,这意味着静态运营模式将转变为实时智能。
在 Oracle AI World 上,我们宣布了面向联合客户的扩展集成方案,并发布了 Snowflake Openflow Connector for Oracle 内部预览版本。这款全内置连接器由 Oracle 与 Snowflake 联合设计,旨在简化操作、提升可靠性,并实现近实时的数据流转。此次合作将 Oracle 成熟的数据库技术与 Snowflake 可扩展的 AI 数据云相结合,使企业能够在发生新事务时将运营数据直接流入到 Snowflake。借助 Oracle 的基于日志的变更数据捕获(CDC)和 Snowflake 的原生流处理功能,该解决方案简化了数据管道、实现低延迟洞察,并支持多种部署环境。
无论是用于 AI、分析还是监管报告,Oracle 与 Snowflake 的集成都使企业能够在规模上释放敏捷性与洞察力,并由双方团队提供深厚专业知识和统一支持保障。
已经过验证架构的两大强力选择
我们理解不同客户有不同的需求,因此我们提供两种近实时数据复制的方法。通过提供选择,我们旨在让每个组织能够针对自身特定需求实现最优数据流。
Snowflake Openflow Connector for Oracle:精简、原生的 Snowflake 体验
为了在 Snowflake 内提供高效且全托管的体验,我们兴奋地推出 Snowflake Connector for Oracle。该连接器基于 Snowflake Openflow 框架设计,兼顾简便性、性能与运营效率。
精简原生体验:该连接器旨在方便使用,无需安装即可直接在 Snowflake 平台内使用,从而降低数据团队的运营成本;
完全托管且可扩展:作为 Snowflake 的内置组件,该连接器由 Snowflake 管理。它能够自动扩展以处理数据量,使工程师无需管理复杂的管道基础设施;
灵活许可:客户可以选择嵌入式 Snowflake 管理许可,或对于已有 Oracle GoldenGate 许可的客户,选择自带许可(BYOL)选项。
GoldenGate:控制、流处理与云端创新
另一种选择是 Oracle 提供的 Oracle Cloud Infrastructure (OCI) GoldenGate,它为企业复制和数据集成设定了标准。
企业级控制:提供精细粒度控制、高性能与 Oracle SGA(System Global Area)事务集成,以及对数百个第三方数据存储的广泛异构复制能力;
为 Snowflake 带来的创新:Oracle 支持通过 Snowpipe Streaming API 对 Oracle 数据库进行流复制,实现低延迟加载。GoldenGate 还提供 Stage-Merge(微批处理)方案,可灵活、低成本地处理复杂 DML/DDL 的合并操作;
流处理与分析:GoldenGate 平台可处理流式提取、转换、加载(ETL)、数据清洗以及时间序列分析,对正在进入 Snowflake 数据仓库和湖仓系统的实时数据事件进行处理。
Openflow 连接器架构深度解析
我们为 Oracle 的 Openflow 连接器设计理念围绕三大支柱展开:企业级性能、运营简便性以及原生 Snowflake 集成。
该连接器的核心基于 Oracle 的原生 XStream API 构建。这是一个经过深思熟虑且至关重要的设计选择。XStream API 共享 Oracle GoldenGate 内部使用的一些强大技术,使 Snowflake 能够直接访问数据库的重做日志。这种基于日志的 CDC 可以捕获已提交的插入、更新和删除操作,对在线事务处理(OLTP)系统的影响最小,相较于基于触发器、基于查询或基于 LogMiner 的 CDC 工具,具有明显优势。
我们优先考虑零占用、无代理架构,在 Oracle 服务器上无需安装或管理或为任何代理打补丁。Oracle 端的配置由数据库管理员通过运行一组标准 SQL 命令来设置和启用 XStream 出站服务器完成的。之后,所有集成都在 Snowflake 中控制。通过 Openflow 用户界面,用户可以配置复制范围(例如,模式、表和列);使用遥测和警报监控管道健康状况;并实时跟踪数据摄取情况。
图 1:通过 Openflow 实现 Oracle 实时 CDC 到 Snowflake 的高层架构
如图 1 所示,Openflow 连接器几乎实时地直接从 XStream 出站服务器队列读取逻辑变更记录(LCRs)。这些变更事件随后使用 Snowpipe Streaming 立即流入 Snowflake 目标表。该内存到内存的直接管道避免了将数据落地到中间文件,从而减少了跳数和潜在故障点,实现端到端延迟仅需几秒。
对于特定需求,复制流程基于灵活的 Openflow 框架构建。团队可以打开 Apache NiFi 画布来扩展管道。例如,团队可以在数据进入 Snowflake 之前通过查询进行数据增强或对敏感 PII 信息进行脱敏处理。
这种灵活架构兼容多种 Oracle 数据库版本:12c R2(12.2)、18c、19c、21c、23ai 和 26ai,可部署在本地、Oracle Exadata、OCI(虚拟机/裸机)以及 AWS RDS Custom for Oracle 环境中。
合作互信,简化赋能
连接关键任务系统,需要深度信任和可靠性。Snowflake Openflow Connector for Oracle 是 Snowflake 与 Oracle 深度协作开发的成果,并提供简化的支持模式。客户只需与 Snowflake 对接,Oracle 合作伙伴则在需要时提供对 Oracle 组件的直接支持。这样避免了繁琐的多方交接,同时保证问题能够协调、高效解决。
对于 Snowflake,这意味着为 AI 数据云接入了关键企业数据源;对于 Oracle,则将其数据库扩展至现代云和 AI 生态系统;对于客户而言,这意味着获得由两大行业领先企业共同支持的最佳架构,确保业务成功落地。
从事务数据到 AI 驱动洞察
最有价值的 AI 应用程序都建立在可信的企业数据之上。几十年来,Oracle 数据库均以无与伦比的性能和完整性支持着关键任务的事务和操作工作负载。
挑战在于如何让这些高保真数据实时可用,以驱动现代分析和智能云应用。Snowflake Openflow Connector for Oracle 在 Oracle 系统与 Snowflake AI 数据云之间创建了无缝、近实时的桥梁。这使得您可以将 Oracle 数据的价值延伸到运营之外,推动预测性洞察和下一代应用,同时不会影响源系统性能。让我们来看看各行业的一些应用场景:
银行、金融服务与保险——用于欺诈检测
以一家零售银行为例,其每小时处理数百万条信用卡交易,所有交易均被记录在高吞吐量的 Oracle OLTP 系统中。现有的欺诈检测模型以批处理方式运行,往往过晚才捕捉到风险。通过 Openflow 连接器或 GoldenGate 在几秒内将每笔交易流入 Snowflake,该银行能够将实时数据输入 Snowpark ML 模型进行实时欺诈检测。可疑交易会在完成前被标记和拦截。此外,Snowflake Cortex AI 的异常检测可以提高敏捷性,比传统批处理系统更快识别欺诈模式。
零售行业——动态库存管理与个性化推荐
一家全球零售商依赖关键的 Oracle 数据库来支撑其核心库存与订单管理系统。但这些关键数据只能在夜间加载到分析平台。借助 Openflow Connector for Oracle 或 GoldenGate 流式复制,该企业能够获得整个业务运营的一致、实时视图,从而解锁 AI 用例。通过 Cortex AI 预测各地区的商品需求,自动触发补货。同时,Snowpark 模型会在发生购买时实时更新客户画像并推送个性化优惠,提升营收。
制造业——预测性维护与供应链优化
一家全球汽车制造商在 Oracle 数据库上运行其生产线和供应链,但将数据传递给分析团队的延迟可能导致关键设备故障可能会造成数小时的停产。通过使用 Openflow 连接器或 Oracle 将传感器和物流数据实时流入 Snowflake,公司能够构建生产运营的实时视图。这使得 Snowpark ML 模型能够在设备故障发生前进行预测,避免停机。同时,Cortex AI 模型监控实时供应链数据,自动重新调配物料以降低中断风险,确保装配线持续运行。
立即开启体验
Openflow Connector for Oracle 现已开放私有预览,公共预览即将推出。如需进一步了解及开始试用,我们邀请您:
Snowflake 推出的 Openflow Connector for Oracle 旨在降低企业数据集成流程的复杂性,同时提升其灵活性。我们十分期待能看到您在这一可靠的数据基础之上构建出令人难以置信的卓越应用。
原文地址:https://www.snowflake.com/en/blog/oracle-database-integration-connector/
点击链接立即报名注册:Ascent - Snowflake Platform Training - China







评论