简单三步骤,使用 DataWorks 建立每日天气预报推送

本文涉及的产品
大数据开发治理平台 DataWorks,不限时长
简介: DataWorks 数据开发提供强大的工作流及调度能力,且近期上线了数据推送节点,这篇文章简单利用 Shell + 数据推送节点来完成每日天气预报的推送工作。

前言


DataWorks 数据开发提供强大的工作流及调度能力,且近期上线了数据推送节点,这边我们就简单利用 Shell + 数据推送节点来完成每日天气预报的推送工作。


效果图


步骤一: 决定信息来源

打开飞猪天气预报页面,找到想要推送的城市天气,这边我们选杭州,打开页面的开发者工具,定位以下信息来源。


  • 温度 (右边为 css 定位): div.header-info-detail-section-weather-temperature span.header-info-detail-section-weather-temperature-text
  • 天气预报 (右边为 css 定位): p.bottom-summary


步骤二: 开发工作流

因为飞猪天气预报页面为 SSR (Server Side Rendering),我们可用 Shell 节点的 curl 及 xmllint 语法根据 DOM 位置就能解析出页面信息,这边需要三个节点。


节点1 新建赋值节点,选用 Shell 语言 (解析飞猪天气预报):


result="$(curl 'https://tianqi.fliggy.com/330100/' -H 'Content-Type: text/html' | xmllint --html --format --recover --nowarning --xpath '//p[@class="'"bottom-summary"'"]//text()' -)";
echo $result | sed 's/\\n/\n/g';



节点2 新建赋值节点,选用 Shell 语言 (解析飞猪天气温度):


result="$(curl 'https://tianqi.fliggy.com/330100/' -H 'Content-Type: text/html' | xmllint --html --format --recover --nowarning --xpath '(//div[@class="'"header-info-detail-section-weather-temperature"'"]//span[@class="'"header-info-detail-section-weather-temperature-text"'"]//text())[1]' -)";
echo $result;


节点3 新增数据推送节点,编辑推送内容:



组织工作流,建立上下游关系:



工作流的推送测试,可以查阅此篇文章


步骤三: 发布工作流


将三个节点的调度时间安排在每日早上八点,提交到发布中心后发布,并于运维中心查看调度状况。透过上述三步骤后,即可于每天早上定时收到天气预报信息。


钉钉展示:



飞书展示:


小结

以上三步骤简单演示如何从网页信息中截取信息,基于同样的方式也能用于股票、机票、酒店等信息截取,而更进一步操作,我们还能利用这些信息再加工,组织出更有价值的资讯。



相关实践学习
基于MaxCompute的热门话题分析
本实验围绕社交用户发布的文章做了详尽的分析,通过分析能得到用户群体年龄分布,性别分布,地理位置分布,以及热门话题的热度。
一站式大数据开发治理平台DataWorks初级课程
DataWorks 从 2009 年开始,十ー年里一直支持阿里巴巴集团内部数据中台的建设,2019 年双 11 稳定支撑每日千万级的任务调度。每天阿里巴巴内部有数万名数据和算法工程师正在使用DataWorks,承了阿里巴巴 99%的据业务构建。本课程主要介绍了阿里巴巴大数据技术发展历程与 DataWorks 几大模块的基本能力。 课程目标  通过讲师的详细讲解与实际演示,学员可以一边学习一边进行实际操作,可以深入了解DataWorks各大模块的使用方式和具体功能,让学员对DataWorks数据集成、开发、分析、运维、安全、治理等方面有深刻的了解,加深对阿里云大数据产品体系的理解与认识。 适合人群  企业数据仓库开发人员  大数据平台开发人员  数据分析师  大数据运维人员  对于大数据平台、数据中台产品感兴趣的开发者
目录
相关文章
|
3月前
|
运维 DataWorks 关系型数据库
DataWorks产品使用合集之DataWorks还有就是对于mysql中的表已经存在数据了,第一次全量后面增量同步的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
53 2
|
2月前
|
存储 分布式计算 DataWorks
DataWorks产品使用合集之表从开发环境提交到线上生产环境的步骤什么
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
27 7
|
3月前
|
分布式计算 DataWorks NoSQL
DataWorks产品使用合集之DataWorks 中同步 MongoDB 数据的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
59 4
|
3月前
|
数据采集 DataWorks 监控
DataWorks产品使用合集之DataWorks中,完成周期任务的开发的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
53 4
|
3月前
|
分布式计算 DataWorks 安全
DataWorks产品使用合集之DataWorks项目分配与安全项目权限配置的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
45 2
|
3月前
|
分布式计算 DataWorks MaxCompute
DataWorks产品使用合集之在DataWorks中,运行诊断进入运行诊断的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
46 1
|
3月前
|
分布式计算 DataWorks 监控
DataWorks产品使用合集之在DataWorks中创建FTP Check节点的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
54 1
|
3月前
|
数据采集 分布式计算 DataWorks
DataWorks产品使用合集之在阿里云的DataWorks中,使用CREATE AS创建分区表的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
74 2
|
3月前
|
SQL JSON 分布式计算
DataWorks产品使用合集之DataWorks一键maxcompute数据同步的操作步骤是什么
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
51 0
|
3月前
|
存储 数据采集 运维
DataWorks产品使用合集之DataWorks创建HTTP触发器节点背景信息的步骤如何解决
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
53 0

热门文章

最新文章

  • 1
    DataWorks操作报错合集之DataWorksUDF 报错:evaluate for user defined function xxx cannot be loaded from any resources,该怎么处理
    54
  • 2
    DataWorks操作报错合集之DataWorks ODPS数据同步后,timesramp遇到时区问题,解决方法是什么
    51
  • 3
    DataWorks操作报错合集之DataWorks配置参数在开发环境进行调度,参数解析不出来,收到了 "Table does not exist" 的错误,该怎么处理
    57
  • 4
    DataWorks操作报错合集之DataWorks中udf开发完后,本地和在MaxCompute的工作区可以执行函数查询,但是在datawork里报错FAILED: ODPS-0130071:[2,5],是什么原因
    55
  • 5
    DataWorks操作报错合集之DataWorks提交失败: 提交节点的源码内容到TSP(代码库)失败:"skynet_packageid is null,该怎么解决
    61
  • 6
    DataWorks操作报错合集之DataWorks在同步mysql时报错Code:[Framework-02],mysql里面有个json类型字段,是什么原因导致的
    87
  • 7
    DataWorks操作报错合集之DataWorks集成实例绑定到同一个vpc下面,也添加了RDS的IP白名单报错:数据源配置有误,请检查,该怎么处理
    51
  • 8
    DataWorks操作报错合集之在 DataWorks 中运行了一个 Hologres 表的任务并完成了执行,但是在 Hologres 表中没有看到数据,该怎么解决
    60
  • 9
    DataWorks操作报错合集之DataWorks使用数据集成整库全增量同步oceanbase数据到odps的时候,遇到报错,该怎么处理
    53
  • 10
    DataWorks操作报错合集之尝试从Oracle数据库同步数据到TDSQL的PG版本,并遇到了与RAW字段相关的语法错误,该怎么处理
    62