Snowflake（旧版）

概述

OneSignal + Snowflake 集成支持两种强大的数据管道：

导出：自动将 OneSignal 的消息事件数据（推送、电子邮件、短信、应用内消息）发送到 Snowflake 进行分析和报告。
导入：将 Snowflake 数据集中的自定义用户事件同步到 OneSignal，以触发自动化 Journey 和个性化消息。

这些集成使您可以完全控制用户参与度数据——支持高级分析和实时行为驱动的消息推送。

将 OneSignal 事件导出到 Snowflake

将消息性能和参与度事件（例如发送、打开、点击）发送到 Snowflake，以便：

构建自定义仪表板和报告
跟踪跨渠道的投递和参与度趋势
将 OneSignal 数据与其他业务数据结合进行分析

要求

OneSignal 专业版计划（免费应用不可用）。
Snowflake 账户
确保您的 Snowflake 账户具有 IMPORT SHARE 和 CREATE DATABASE 角色。
- 我们建议使用 ACCOUNTADMIN 角色来接受共享。

设置步骤

1. 注册

要激活 Snowflake 集成，您需要通过 OneSignal Marketplace 列表请求访问消息事件数据。之后我们将与您的团队联系以获取更多信息。

2. 提供账户信息

与您的团队联系后，您需要向我们提供一些详细信息，以便我们与您共享数据。我们需要您的 Snowflake 账户 ID 和 Snowflake 组织 ID。获取该信息的最简单方法是点击”复制账户标识符”按钮（如下所示）。

您应该通过 OneSignal Marketplace 列表与我们联系。但是，如果您对提供账户信息有任何其他疑问，可以发送电子邮件至 snowflake-data-sharing@onesignal.com

一旦您被接受加入该计划，请留意以下几项：

OneSignal 发来的欢迎您加入该计划的电子邮件
Snowflake 发来的通知数据共享已完成的电子邮件

3. 在 Snowflake 中接受数据共享

收到 Snowflake 发来的数据共享完成通知电子邮件后，您应该能够登录 Snowflake 应用并接受数据共享。导航至数据 → 私有共享，您应该能够看到新的私有共享列表。点击 Get 后，您的数据将开始复制到您的区域。

注意：如果 Get 按钮不可用但有 Request 按钮，则表示尝试进行共享的角色权限不包括 CREATE DATABASE 或 IMPORT SHARE。我们建议切换到 ACCOUNTADMIN 角色。数据复制需要一些时间。数据可用后，Snowflake 将发送另一封电子邮件。您应该会看到如下所示的对话框

数据准备就绪后，您的列表应该会显示一个新的 Get 按钮。点击 Get 按钮，您将看到一个新的对话框

将数据库和数据库角色的名称设置为您喜欢的名称。然后点击 Get

完成！数据现在正在从 OneSignal 同步到 Snowflake。同步频率设置为每 24 小时一次，因此初始数据可能要到第二天才能获得。

事件和属性

Snowflake Marketplace 上可用数据的概述

消息事件数据

有关更多详细信息，请参阅事件流。对于用户生成的每个消息事件，以下元数据将附加到记录中。

列名	类型	描述	示例
event_id	UUID	表示事件的唯一 ID	`dc76df03-287c-403a-aabd-b2d4fe44e5c6`
event_kind	string	发生的事件类型。事件类型列表可以在此处找到。	`message.email.opened`
event_impression_timestamp	unix_timestamp	OneSignal 处理事件的时间	`1684951205`
subscription_id	UUID	表示设备/订阅的唯一 ID	`6e8b6978-75a4-4882-878c-2d15a78c2409`
subscription_language	string	此订阅的语言	`en`
subscription_timezone	integer	此订阅的指定时区	`-25200`
subscription_device_type	string	此订阅使用的设备类型。	`SMS`
onesignal_id	UUID	产生展示的用户的 onesignal_id	`dc76df03-287c-403a-aabd-b2d4fe44e5c6`
external_id	string	产生展示的用户的 external_id	`MyExternalId`
message_id	UUID	表示消息的唯一 ID	`dc76df03-287c-403a-aabd-b2d4fe44e5c6`
message_name	string	通知/消息的人类可读 ID	`Campaign 1`
message_title	string	通知/消息的标题。目前仅限英语	`Bonus 50 coins when you play!`
message_body	string	消息的正文。（截断）目前仅限英语。	`Play against your friends and earn an additional...`

消息事件类型

有关更多详细信息，请参阅事件流。消息事件是我们在 Snowflake Marketplace 上提供的第一类数据。如果您需要其他类别的数据，请通过 snowflake-data-sharing@onesignal.com 与我们联系！

数据保留

通过 Snowflake 从 OneSignal 共享的数据保留 30 天。为确保在此时间范围之外保留数据，我们建议您将相关数据复制到您自己的表中。

从 Snowflake 导入事件

将行为事件数据从 Snowflake 发送到 OneSignal，以便：

根据用户活动触发 Journey
根据行为数据个性化消息

要求

访问自定义事件（目前处于测试阶段）
升级账户计划（免费应用不可用）。

具有数据仓库访问权限的 Snowflake 账户
存储在 Snowflake 表或视图中的事件数据
从 OneSignal 到您的 Snowflake 实例的网络连接
具有适当权限的用户凭证

设置步骤

为 OneSignal 创建专用角色

按照 Snowflake 最佳实践创建角色层次结构：

-- Create a role for the census user
CREATE ROLE CENSUS_ROLE;

-- Ensure the sysadmin role inherits any privileges the census role is granted
GRANT ROLE CENSUS_ROLE TO ROLE SYSADMIN;

创建专用数据仓库

为 OneSignal 操作创建经济高效的数据仓库：

-- Create a warehouse for the census role, optimizing for cost over performance
CREATE WAREHOUSE CENSUS_WAREHOUSE WITH
    WAREHOUSE_SIZE = XSMALL
    AUTO_SUSPEND = 60
    AUTO_RESUME = TRUE
    INITIALLY_SUSPENDED = FALSE;

GRANT USAGE ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;
GRANT OPERATE ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;
GRANT MONITOR ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;

创建用户并授予权限

创建 OneSignal 用户并授予对事件数据的访问权限：

-- Create the census user
CREATE USER CENSUS WITH
    DEFAULT_ROLE = CENSUS_ROLE
    DEFAULT_WAREHOUSE = CENSUS_WAREHOUSE
    PASSWORD = '<strong-unique-password>';

GRANT ROLE CENSUS_ROLE TO USER CENSUS;

-- Grant access to your event data (replace with your actual database/schema)
GRANT USAGE ON DATABASE "<your-database>" TO ROLE CENSUS_ROLE;
GRANT USAGE ON SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON ALL TABLES IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON FUTURE TABLES IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON ALL VIEWS IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON FUTURE VIEWS IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;

创建记账数据库（高级同步引擎）

为 OneSignal 的同步状态管理创建私有数据库：

-- Create a private bookkeeping database
CREATE DATABASE "CENSUS";
GRANT ALL PRIVILEGES ON DATABASE "CENSUS" TO ROLE CENSUS_ROLE;

CREATE SCHEMA "CENSUS"."CENSUS";
GRANT ALL PRIVILEGES ON SCHEMA "CENSUS"."CENSUS" TO ROLE CENSUS_ROLE;
GRANT CREATE STAGE ON SCHEMA "CENSUS"."CENSUS" TO ROLE CENSUS_ROLE;

如果使用基本同步引擎或只读模式，请跳过此步骤。

配置身份验证

设置密钥对身份验证（推荐）以增强安全性：

按照 Snowflake 文档生成公钥/私钥对
在 Snowflake 用户上配置公钥
在 OneSignal 的连接设置中使用私钥

或者，您可以使用密码身份验证（已弃用 - 将于 2025 年 11 月被阻止）。

连接到 OneSignal

在 OneSignal 中，前往 数据 > 集成，然后点击 添加集成。选择 Snowflake 并提供以下连接详细信息：

账户名称： 您的 Snowflake 账户标识符（例如 abc123.us-east-1）
数据仓库： CENSUS_WAREHOUSE
用户： CENSUS
数据库： 您的事件数据数据库名称
架构： 您的事件数据架构名称
身份验证： 密钥对（提供私钥和可选密码短语）

事件数据映射

将您的映射到 OneSignal 的自定义事件格式：

OneSignal 字段	描述	必需
`name`	`event_name`	事件标识符	是
`external_id`	`user_id`	用户标识符	是
`timestamp`	`event_timestamp`	事件发生时间	否
`properties`	`event_data`	否

示例事件表架构

-- Example Snowflake event table
CREATE TABLE analytics.user_events (
    event_id STRING,
    event_name STRING NOT NULL,
    user_id STRING NOT NULL,
    event_timestamp TIMESTAMP_TZ DEFAULT CURRENT_TIMESTAMP(),
    event_properties VARIANT,
    session_id STRING,
    device_type STRING
);

SQL 查询模式

编写自定义 SQL 查询以转换您的事件数据：

-- Example: Recent high-value events
SELECT
    event_name,
    user_id,
    event_timestamp,
    event_properties
FROM analytics.user_events
WHERE event_timestamp >= DATEADD(day, -7, CURRENT_TIMESTAMP())
    AND event_properties:value::NUMBER > 100
ORDER BY event_timestamp DESC;

高级配置

管理数据仓库成本

使用 X-Small 数据仓库大小以优化成本
配置自动挂起（60 秒）和自动恢复
在非高峰时段安排同步
考虑与其他批处理系统共享数据仓库

实时同步支持

要进行实时事件处理，请在事件表上启用变更跟踪：

ALTER TABLE "analytics"."user_events" SET CHANGE_TRACKING = TRUE;

网络安全

如果使用 Snowflake 的允许 IP 网络策略，请将 OneSignal 的 IP 地址添加到您的允许列表。请联系 OneSignal 支持以获取当前的 IP 范围。

限制

复杂的分析查询可能会影响数据仓库性能和成本
用户/密码身份验证将于 2025 年 11 月弃用
CENSUS 数据库仅保留用于 OneSignal 操作

断开与 OneSignal 的数据共享

请发送电子邮件至 snowflake-data-sharing@onesignal.com 以请求停用您与 OneSignal 的数据共享。

常见问题

我应该使用哪种身份验证方法？

使用密钥对身份验证（推荐）。从 2025 年 11 月开始，Snowflake 将阻止用户/密码身份验证。

我可以使用现有的数据仓库吗？

可以，您可以与其他批处理系统（如 dbt 或 Fivetran）共享数据仓库以优化成本。确保数据仓库具有足够的容量来满足您的事件处理需求。

如何优化成本？

使用 X-Small 数据仓库大小
配置激进的自动挂起（60 秒）
在非高峰时段安排同步
使用每小时/每天同步而不是连续同步

​概述

​将 OneSignal 事件导出到 Snowflake

​1. 注册

​2. 提供账户信息

​3. 在 Snowflake 中接受数据共享

​事件和属性

​消息事件数据

​消息事件类型

​数据保留

​从 Snowflake 导入事件

​事件数据映射

​示例事件表架构

​SQL 查询模式

​高级配置

​管理数据仓库成本

​实时同步支持

​网络安全

​限制

​断开与 OneSignal 的数据共享

​常见问题

​我应该使用哪种身份验证方法？

​我可以使用现有的数据仓库吗？

​如何优化成本？

概述

将 OneSignal 事件导出到 Snowflake

1. 注册

2. 提供账户信息

3. 在 Snowflake 中接受数据共享

事件和属性

消息事件数据

消息事件类型

数据保留

从 Snowflake 导入事件

事件数据映射

示例事件表架构

SQL 查询模式

高级配置

管理数据仓库成本

实时同步支持

网络安全

限制

断开与 OneSignal 的数据共享

常见问题

我应该使用哪种身份验证方法？

我可以使用现有的数据仓库吗？

如何优化成本？