为了便于数据分析,构建一张ltv_activity表,记录从客户初次接触到最终签约过程,不同阶段用ltv_activity_stage的不同值来表示,其他信息作为该活动表的字段,请注意同样的角色在原先的不同表中有不同表示(比如saler.name和attend_belong_cc都是指销售),在ltv_activity应该用同一个字段记录,用不同的ltv_activity_stage值来区分,活动发生的时间在原先表中也有不同字段,在ltv_activity中统一为ltv_activity_time。其他最终要输出的字段信息都可以沿用到ltv_activity中。请给出ltv_activity表的创建语句,备注用中文。
假定原先表(除了tmp_market_stat之外,因为是临时表)中的数据变更都可以通过binlog传递给进行ETL转换的Python程序,该程序监听binlog并能解析,并能转换数据存入ltv_activity。请给出该Python的程序代码。
网友评论