一种基于大数据的营销经营画布批量决策的方法

本发明公开了一种基于大数据的营销经营画布批量决策的方法。该方法采用广度优先搜索算法将营销经营画布的策略节点按层级关系拆解为L1至Ln规则层，通过预编译技术将规则集转换为可执行的SQL语句并存储至分布式缓存系统。系统运用Apache Spark Structured Streaming分布式流计算引擎按层级顺序执行规则计算，其中第n层规则以第n‑1层计算结果为输入，通过交集运算实现并行处理。计算结果转换为用户ID与命中指令集的键值对格式，经分布式聚合后输出至Kafka消息队列。系统还集成了Flink CDC技术实现增量计算优化，仅对变更策略节点的下游层级进行重新计算，显著提升资源利用效率。该技术方案适用于金融、电商等行业的大规模精准营销场景。