场景
在电商公司中常见的一个场景：当用户浏览商品页面时，系统可以从Kafka中抽取用户的行为事件（如点击商品、加入购物车、购买等），实时分析用户的兴趣和购买意向，构建诸如母婴产品爱好者、对科技产品有兴趣等实时标签。这些标签可以立即用于推荐系统，向用户推荐相关的产品，提高转化率和用户满意度
以母婴产品爱好者为例，计算用户近12小时内，用户对于母婴产品的点击数和加购车数，当点击数大于100或者加购物车数大于10，该用户就会被打上“母婴产品爱好者”的标签。在此过程中Dataphin是如何从Kafka中实时抽取用户的行为事件，并生成实时标签？
解决方案及功能
前提条件
已创建Kafka数据源，创建详情请参见创建Kafka数据源。
创建实时数据集前需创建用于实时数据集开发的事件。
创建实时数据集前请先创建数据集所归属的标签项目。
重要通过事件预加工新建实时数据集需在项目中添加实时计算源。
操作步骤
在标签 > 事件中心 > 属性管理中维护属性信息，包含Kafka中每个topic内的key-value对所包含的信息。在本例中，用户ID作为key，行为类型、商品类别、操作时刻及商品ID作为value。
在标签 > 事件管理页面创建事件，填写基本信息和元表结构及属性映射，并选择是否时序字段。创建步骤详情请参见创建及管理事件。
前往标签 > 工作台 > 实时数据集中创建实时数据集，创建方式选择数据来源于事件，分别创建用户加入购物车行为数据集和用户点击行为数据集，其中主键为topic中的key。创建步骤详情请参见通过事件预加工创建实时数据集。
在标签 > 工作台 > 实时标签中，使用用户加入购物车行为数据集和用户点击行为数据集创建指标映射实时标签，创建完成后单击发布。
在标签 > 工作台 > 实时标签中，创建母婴产品爱好者的规则组合标签，创建完成后单击发布。
母婴产品爱好者实时标签创建完成后可上架至市场，供标签应用（实时推荐系统）调用，可实时向用户推荐相关产品，提高转化率和用户满意度。
