You need to enable JavaScript to run this app.
导航

标签资产输出

最近更新时间2023.12.12 16:49:23

首次发布时间2023.07.19 14:11:00

1. 产品概述

支持用户将CDP中的标签资产输出到自有数据库,以便进行灵活处理应用或分析工作。

2. 使用限制

需要具备功能权限(即项目中心-权限-编辑资产输出任务的权限)+资源权限(需要用到的标签&属性的权限)+对应的数据权限,才可以使用该功能。

3. 操作步骤

以输出到MaxCompute为例,操作步骤如下:

第一步:配置MaxCompute数据连接

1.点击 数据融合 > 数据连接 。 2.在数据连接目录左上角,点击 新建数据连接 按钮,选择 MaxCompute

3.填写所需的基本信息,并进行 测试连接

名称描述
数据连接名称可对名称进行修改。请输入规范的名称,不要使用特殊字符,前后不能包含空格。
服务器连接MaxCompute项目的服务器地址。
Project Name目标MaxCompute项目的名称。
Access ID和Access Secret具备目标MaxCompute项目访问权限的Access ID和Access Secret。

4. 连接成功后点击保存。

第二步:配置资产输出渠道

1.点击 项目中心 > 资产输出 > 渠道管理
2.在自定义渠道页面选择 添加渠道应用 ,填写渠道名称、服务账号及唯一标识(即应用方可以指定唯一code作为访问api的标识),点击 授权 即可。

第三步:创建资产输出任务

方式1:通过离线数仓高表输出

输出的标签数据表结构的样例如下:

基准ID标签ID标签值业务日期
63528953748201638462087232023/6/13
6352837274820163846208745252023/6/14
6352895374862973846208721大学2023/6/15
7362895374820163846208789白金会员2023/6/16

操作步骤如下:
1.点击 项目中心 > 资产输出 > 资产输出任务
2.点击 新建任务 开始配置任务信息,包括任务名称、主体、渠道。

3.选择输出内容方式 离线数仓高表 ,类型为 标签 并勾选需要输出的标签。

4.在服务配置位置,输出频率支持 定时输出(支持小时级、天、周、月)单次输出 ,更新方式支持 全量更新 ,输出连接方式支持 MaxCompute、OceanBase MySQL、星环Inceptor、内置Hive,本示例中可选 MaxCompute,并选择对应的数据库表。
5.选择 任务有效时间 后,点击右上角 保存 即可。
alt

方式2:通过离线数仓宽表输出

输出的标签数据表结构的样例如下:一个标签一列

基准IDXX_ID,如用户ID性别年龄会员等级标签……业务日期
6352895374820163846208753191623白金……2023/6/13
6352837274820163846208763804245黄金……2023/6/14
6352895374862973846208753827423白银……2023/6/15
7362895374820163846208744218730白银……2023/6/16

操作步骤如下:
1.点击 项目中心 > 资产输出 > 资产输出任务
2.点击 新建任务 开始配置任务信息,包括任务名称、主体、渠道。

3.选择输出内容方式 离线数仓宽表 ,类型为 标签 并勾选需要输出的标签,同时支持选择ID类型(下拉支持选择的ID为用户在ID图谱构建页面中配置的ID,其中无baseid选项。)

4.在服务配置位置,输出频率支持 定时输出(支持天、周、月)单次输出 ,更新方式支持 全量更新 ,输出连接方式支持 MaxCompute、OceanBase Oracle、OceanBase MySQL、星环Inceptor、内置Hive,本示例中可选 MaxCompute,并选择对应的数据库表。
5.选择 任务有效时间 后,点击右上角 保存 即可。
alt

方式3:通过API输出

1.点击 项目中心 > 资产输出 > 资产输出任务
2.点击 新建任务 开始配置任务信息,包括任务名称、主体、渠道。

3.选择输出内容方式 API ,资产为 单资产 , 类型为标签 并勾选需要输出的标签。

4.点击 文档地址 跳转到API调用说明文档,根据以下指引接入API后,服务即可生效。
点击前往 OpenApi使用指导手册,通过 查询名 定位相关接口调用说明,具体接口查询名为:feature_h、get_all_tags、delete_tag、update_tag、get_manual_tags、get_tag_values。

方式4:通过Kafka输出

当通过Kafka方式输出标签单资产时,操作如下:
1.点击 项目中心 > 资产输出 > 资产输出任务
2.点击 新建任务 开始配置任务信息,包括任务名称、主体、渠道。

3.选择输出内容方式 Kafka,资产为 单资产 , 类型为标签 并勾选需要输出的 实时标签 填写对应服务配置信息即可。支持点击 测试 校验对应输出通道是否完成配置。


当通过Kafka方式将实时标签的资产变更场景(当条件由A变为B时触发、当条件为B时触发) 向用户侧的 Kafka 中写入时,实现路径如下:

  • 由用户提供 kafka 服务,在创建任务时,输入 kafka broker 和 topic 信息

  • CDP 将实时数据推送到用户的 kafka 服务上

  • 用户通过订阅自己的 kafka 服务进行接收实时变更数据

配置操作如下:
1.点击 项目中心 > 资产输出 > 资产输出任务
2.点击 新建任务 开始配置任务信息,包括任务名称、主体、渠道。

3.选择输出内容方式 Kafka ,资产为 资产变更 , 类型为标签 ,并填写触发条件。

标签变更数据示例如下:当条件由A变为B时触发

{
    "dataAssertraskId": 40,
    "from": {
        "id": "0",
        "env": null,
        "entity_id": 1,
        "tag_id": 642,
        "p_date": "2023-03-17",
        "original_value": "",
        "tag_value_type": "string",
        "tag_value_date": null,
        "tag_value_double": null,
        "tag_value_datetime": null,
        "tag_value_string": "篮球",
        "tag_value_bigint": null,
        "tag_value_array_string": null,
        "compute_time": 1579025413844
    },
    "to": {
        "id": "0",
        "env": null,
        "entity_id": 1,
        "tag_id": 642,
        "p_date": "2023-03-17",
        "original_value": "",
        "tag_value_type": "string",
        "tag_value_date": null,
        "tag_value_double": null,
        "tag_value_datetime": null,
        "tag_value_string": "篮球",
        "tag_value_bigint": null,
        "tag_value_array_string": null,
        "compute_time": 1579025413844
    }
}

当条件为B时触发:

{
    "id": "0",
    "dataAssertraskId": 40,
    "env": null,
    "entity_id": 1,
    "tag_id": 642,
    "p_date": "2023-03-17",
    "original_value": "",
    "tag_value_type": "string",
    "tag_value_date": null,
    "tag_value_double": null,
    "tag_value_datetime": null,
    "tag_value_string": "篮球",
    "tag_value_bigint": null,
    "tag_value_array_string": null,
    "compute_time": 1579025413844
}

4.填写对应服务配置信息即可。支持点击 测试 校验对应输出通道是否完成配置。完成后点击右上角 保存 即可。