Snowflake（旧版）

OneSignal 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 列表与我们联系。但是，如果您对提供账户信息有任何其他疑问，可以发送电子邮件至 [email protected]

复制 Snowflake 账户标识符

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

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

Snowflake 数据共享通知电子邮件

3. 在 Snowflake 中接受数据共享

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

Snowflake 私有共享界面

注意：如果 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 上提供的第一类数据。如果您需要其他类别的数据，请通过 [email protected] 与我们联系！

数据保留

通过 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 的数据共享

请发送电子邮件至 [email protected] 以请求停用您与 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 的数据共享

常见问题

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

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

如何优化成本？