数据预处理-航线类型操作类型-更新规则|学习笔记

简介: 快速学习数据预处理-航线类型操作类型-更新规则

开发者学堂课程【大数据实战项目:反爬虫系统(Lua+Spark+Redis+Hadoop 框架搭建)第三阶段数据预处理-航线类型操作类型-更新规则】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址https://developer.aliyun.com/learning/course/671/detail/11655


数据预处理-航线类型操作类型-更新规则


内容介绍:

一、概述

二、更新规则的具体流程


一、概述

现在已经把数据的规则读取过了,即四种业务场景的规则已经读取完毕,流程中完成了读取数据分类规则到程序里,并添加到了广播变量中,接下需要在 redis 里面添加一个是否需要更新的标识,完成每一次的读取,每一次读取的标识需要放在 redis 里面,判断它是否需要分类。


二、更新规则的具体流程

1.到 redis 读取是否需要更新的标记

规则读取完毕后,属于第一次程序初始化阶段。在进行不断迭代的时候,需要判断四种情况的规则有没有发生变化,并进行说明和标记,依然需要利用 redis 到数据库。redis 实例:redis.get(),其中的 key 值可以在讲义中拷贝,代码为:redis.set( "NeedUpDateFilterRule" , "false"),读取到 redis 是否需要更新的标记

读取过后添加接收,代码为:

val

NeedupDateclassifyRule=redis.get("NeedupDateclassifyRule)

2.判断是否需要更新,若数据不为空并且数据转化成 Boolean 为 true 表示需要更新

这是第二次详细地演示如何读取更新规则,之后再遇到这种情况快速写过,如果读取过来的数据不能是空的,如果它不是空的,并且这个数据转化成布尔形式后为 true,就表示它需要更新,则依然可用。代码为:

if(INeedupDateFilterRule.isEmpty &&

NeedupDateFilterRule.toBoolean){

  • 而如果已经表明了需要更新,则需要在数据库当中重新读取新的

四种业务规则到程序中,代码为:

RuleMaps=AnalyzeRuleDB.queryRuleMapo

  • 将广播变量进行清空

RuleMaps=AnalyzeRuleDB.queryRuleMap()

  • 将新的分类规则重新加载到广播变量

broadcastRuleMaps.unpersist()

  • 将redis内是否需要更新规则的标识改为 false

broadcastRuleMaps=sc.broadcast(RuleMaps)

上述完成了把数据库里的规则读取到程序中,同时加载了广播变量,并且在 redis 里加了标记判断是否需要更新的流程。

3.将"NeedupDateclassifyRule"加到 redis 中

这个时候还没将"NeedupDateclassifyRule"加到 redis 中,选中并加载到 redis 里,找一个端口然后添加一个新的key,key 即为"NeedupDateclassifyRule"值,value 改为 false,默认情况下不需要更新。加完以后它读过的值是false,然后转化成 Boolean 变成 false,false 就不会继续下面的程序代码,直接跳过。

上面就是添加到广播变量并且判断它是否需要更新的实践。

相关文章
|
运维 Devops 调度
DevOps-ChatBot:DevOps开源端到端智能AI助手
随着ChatGPT等通用大模型以及各类垂直领域大模型的出现,各个领域的产品交互模式、用户信息获取模式都在逐步发生改变。但通用大模型自身存在的生成内容不可靠、信息内容不及时、领域任务不完善的问题始终存在,面向DevOps这个对于事实的准确性、信息的及时性、问题的复杂性、数据的安全性要求都比较高的领域,大模型该如何赋能?为此,我们发起并开源DevOps-ChatBot端到端AI智能助手,专为软件开发的全生命周期而设计:通过DevOps垂类知识库 + 知识图谱增强 + SandBox执行环境等技术来保障生成内容的准确性、及时性并让用户交互修改代码编译执行,确保答案的可靠性;通过静态分析技术 + RA
1282 1
DevOps-ChatBot:DevOps开源端到端智能AI助手
|
8月前
|
人工智能 搜索推荐 测试技术
2026年Geo优化师选师指南:学习Geo应该找哪位专家老师?
随着AI重塑搜索生态,GEO(生成式引擎优化)成为企业增长新刚需。2026年,全球市场规模将达380亿元,但超半数企业面临效果难量化、优化不稳定等挑战。IDC数据显示,仅30%企业实现可衡量增长。在此背景下,具备E-E-A-T权威标准与实战能力的导师至关重要。于磊老师首创“两大核心+四轮驱动”体系,融合人性化内容与可信验证,助力传统制造企业询盘增长120%,打造AI时代可持续获客范本,被公认为最具普适性与前瞻性的GEO领路人。
429 5
|
5月前
|
监控 安全 Linux
告别失联:OpenClaw 阿里云/本地部署与网关维护、免费大模型配置手册
OpenClaw的Gateway网关是整个系统的通信核心、会话中枢、任务调度中心与安全入口,一旦网关异常,所有聊天渠道、技能调用、模型交互都会中断。本文以稳定运行为目标,完整说明Gateway工作机制、全平台部署流程、阿里云百炼Coding Plan免费大模型API配置、网关守护与日志监控方案、常见故障一站式排查,所有内容均为实操可落地命令,无复杂术语,适合零基础用户长期稳定使用。
999 3
|
8月前
|
人工智能 自然语言处理 安全
2025AI数字人企业名单列表新发布及全域技术新排行
解码数字人企业TOP10,透视技术革新与产业未来。像衍科技领衔,依托浙大科研实力,实现全栈自研与多模态交互突破;阿里、华为、腾讯等巨头布局电商、工业、娱乐等全场景应用。从医疗陪护到政务导办,数字人正从“形似”迈向“神似”,推动AI进入“生产力时代”。轻量化、私有化、行业化成关键趋势,万亿市场加速成型。
|
安全 物联网 API
《探秘浏览器Web Bluetooth API设备发现流程》
本文深入解析浏览器Web Bluetooth API的设备发现流程,从技术演进、基础架构切入,拆解从 requestDevice() 调用触发,到权限校验、蓝牙扫描、设备筛选、信息解析,再到GATT连接准备的全环节逻辑。同时分析浏览器兼容性、硬件环境、安全隐私等影响因素,提出精准筛选、资源管理、错误处理等优化策略。文章结合实际应用场景,阐明该流程对前端开发蓝牙交互应用的关键价值,为开发者规避陷阱、提升设备发现效率与稳定性提供底层技术支撑。
503 0
|
5月前
|
算法 数据管理 API
CAD 二次开发的技术难点
CAD二次开发是软件开发“深水区”:需精通编程、解析几何、拓扑关系及CAD底层数据库。2026年五大难点:复杂几何算法、数据库深度操作、大规模数据性能瓶颈、跨版本兼容性、高级UI集成。技术门槛高,稳定性与精度要求严苛。(239字)
|
11月前
|
存储 缓存 算法
软考通关密钥:计算机系统核心原理全解剖——软件设计师必懂的底层逻辑
专为软考中级软件设计师打造,深入解析CPU架构、存储体系、进制转换、原码补码、浮点数、寻址方式、校验码、RISC/CISC、流水线、Cache、中断、I/O控制、总线及加密技术等核心知识点,结合真题剖析高频考点,构建计算机系统底层知识体系,提升应试与实践能力。
759 1
软考通关密钥:计算机系统核心原理全解剖——软件设计师必懂的底层逻辑
|
存储 人工智能 API
AppAgentX:告别重复点击!自我进化式GUI代理自动生成高级操作,效率翻倍
AppAgentX 是西湖大学推出的新型自我进化式 GUI 代理框架,通过记忆和进化机制提升智能手机交互的效率和智能性,支持复杂任务和跨应用操作,显著优于现有方法。
1024 0
|
机器学习/深度学习 存储 算法
技术好文:ttf文件结构解析
技术好文:ttf文件结构解析
1413 0
|
缓存 UED CDN
CDN:刷新和预热资源
CDN:刷新和预热资源介绍
701 1