第5章〓健康医疗大数据分析 5．1移动健康大数据来源与获取 在收集数据时，数据来源包含两种方式。第一种方式就是所谓的直接来源，通过直接来源获取的数据就是第一手数据，这类数据主要来源于直接的调查或实验的结果。第二种方式就是间接数据，也称为第二手数据，第二手数据一般来源于他人的调查或实验，是对结果进行加工整理后的数据。在移动健康大数据中，包含通过可穿戴式设备(如健康手环、智能体脂秤等)直接记录的个人健康数据，也包含通过移动医疗APP记录的与健康相关的信息。 5．1．1可穿戴式设备 可穿戴式设备即直接穿在身上，或是整合到用户的衣服或配件中的一种便携式设备。可穿戴式设备不仅仅是一种硬件设备，还是可通过软件支持以及数据交互、云端交互来实现强大的功能的设备。可穿戴式设备将会对我们的生活、感知带来很大的转变。随着传感技术的发展，可穿戴式设备的种类越来越多样化，智能可穿戴式设备作为新型的便携式电子产品类别，主要产品有智能手表、智能手环、无线耳机等，通过蓝牙连接或APP的支持，与手机建立实时传输或数据同步。智能可穿戴式设备有着便携式的特点和多功能化的交互式体验。目前，智能手表/智能手环的市场份额主要由手机厂商和早布局的厂商占据，国内智能手表/手环主要有华为、荣耀、小米、红米、oppo、vivo、一加、努比亚等手机品牌，也有华米、出门问问、小天才等专注于智能穿戴的品牌，国外智能手表/手环品牌主要有苹果、三星、Fitbit、佳明、boAt等。未来智能可穿戴式设备的功能将不只局限于监测心率、计步、感应体温、睡眠等，还能检测到生理指标的异常，在医疗健康方面起到切实的作用。 智能手表/手环在医疗健康方面提供的检测功能主要是记录用户的运动习惯、健身效果、睡眠质量、饮食安排等一系列相关的数据，并且可以将这些数据同步到用户的移动终端设备中，终端设备可能会根据自己的“分析功能”给出相关建议，并将用户分为不同的状态(健康状态、亚健康状态、生病状态)，起到通过数据指导健康生活的作用。然而，对于数据监测状态，大部分人所处的一种状态是无数据或极少数据监测的状态(此时，将其定义为无监测状态)，一旦感觉身体不适，才来到医院进行检查，并获得此次检查的身体数据(此时，可将其定义为准确监测状态)，以实现健康状态评估和疾病精准诊断。 5．1．2移动医疗APP 移动医疗为一个新兴行业，从2009年起，我国为满足群众医疗健康需求，缓解医疗卫生发展不均衡矛盾而出台多项推动移动医疗发展的利好政策。互联网的特征表现在： 信息量大、使用频率高、用户平均收入低、维护成本低、标准化易复制、爆点之后赢者通吃、边际成本为零； 而医疗行业的特征表现在： 用户平均收入高、成本高、属地化难以赢者通吃、支付方与决定者不对等、政策及监管的壁垒等。移动医疗通过移动通信技术可以快速提供给患者对应的医疗服务和信息。与传统医疗相比，移动医疗对医疗资源配置进行了优化利用，提高了患者、医生、医院之间的问诊效率，省时更省心。 移动医疗APP发展至今已经具备比较成熟的商业模式，根据移动医疗APP功能，可以分为以下几类： (1) 在线寻医问诊类： 如平安好医生、春雨掌上医生、丁香医生、阿里健康等。 在线问诊类APP是用户通过付费方式向医生问诊，医生提供相应医疗方案。可以利用图文、视频、电话等方式沟通。在线问诊可以说是现在移动医疗APP市场竞争最激烈的领域，平台需要提供大量优质的线上医生资源，来为用户提供专业的医疗服务。服务形式有平台分发、医生抢单、用户付费指定医生、付费悬赏等。在线问诊尤其在疫情期间发挥了巨大的作用。 (2) 预约挂号/导诊： 如好大夫在线、健康160、趣医院、挂号网等。 医疗导诊APP因渠道丰富，解决了用户挂号、候诊、缴费排队时间长等问题，同时帮助医院进一步优化了医疗资源匹配方式和服务流程，提升了用户就医体验而备受好评。主要通过连接医院应用程序编程接口（application programming interface，API）、数据接口或号源池的方式来实现挂号、导诊等功能。但受医院开发、运维能力以及数据安全稳定等因素制约，并非所有医院都可以提供API接口，目前市面上只有少部分挂号APP具备这种模式。 (3) 医药服务类： 如叮当快药、1药网、用药助手。 受国家发展医药电商政策影响，医药电商资质审核进一步扩大，不再被互联网药品资质牵制，医药O2O平台开始快速发展，市场上开始出现自营医药B2C、平台医药B2C、医药O2O等服务企业。 (4) 健康管理类(饮食、数据监测)： 如keep、微脉、悦动圈等。 这类APP通过鼓励用户参与平台各种活动，上传自己身体、健康、饮食。睡眠等数据，形成用户健康档案，为用户提供定制化健康管理方案，一部分平台经过前期用户沉淀已经建立自己的生态圈，开始向线上商城等更多元的方向发展。 (5) 健康知识库： 如健康汇、掌上糖医等。 这类APP主要整合有价值的健康医疗信息，形成相应的健康知识库。表现形式包含有文字、图片、动画、视频，并且还会有专题知识讲座，不管是小孩还是老人看了图文结合的介绍后都能理解。 5．1．3开源健康数据获取 穿戴式设备、移动医疗APP多元化发展催生了移动健康大数据，而这些设备或APP都会考虑保护用户数据隐私，因此很难直接获取到数据。如何获取这些直接或间接产生的数据进行下一步分析成为目前的难题。 Kaggle成立于2010年，是一个进行数据发掘和预测竞赛的在线平台。企业和研究者可在其上发布数据，统计学者和数据挖掘专家可在其上进行竞赛，通过“众包”的形式以产生最好的模型。Kaggle上的内容可以分为竞赛（competitions）、数据集（datasets）、模型（models）、代码（code）等模块，如图51所示。 图51Kaggle官网 1． 竞赛 Kaggle上的竞赛有各种分类，例如奖金极高、竞争激烈的“Featured”，相对平民化的 “Research”，等等。但整体的项目模式是一样的，就是通过出题方给予的训练集建立模型，再利用测试集算出结果用来评比。参加比赛的流程相当简单，简单来说就是分为Download、Build、Submit三个步骤，如图52所示。 (1) Download 每个比赛都会有较详细的子页面来介绍背景、数据集、评价指标和提交方式等相关要求。Kaggle负责对这一过程以及竞赛模型的构建、数据的匿名化以及集成最终获胜的模型提供咨询服务。 (2) Build 参赛者在本地构建模型后，输入比赛提供的数据集进行训练，得到的预测结果上传回Kaggle。 (3) Submit 参赛者相互竞赛以获得最优的模型，参赛者提交答案后会根据预测精度被立即评分，并实时显示。 由于这类问题并没有标准答案，只有无限逼近最优解，所以这样的模式可以激励参与者提出更好的方案，甚至推动整个行业的发展。 2． 数据集 Kaggle上的数据集服务收集了许多公共的数据集(包含计算机视觉、NLP、教育、农业、互联网等数据)，并且提供数据下载、介绍、相关脚本（scripts）以及独立的论坛等服务。利用Kaggle上的数据集，通过简单下载，就可以自己在本地或在线进行数据挖掘、分析。Kaggle上的数据集竞赛如图53所示。 图52Kaggle官网竞赛 图53Kaggle官网数据集竞赛 关于Kaggle上的数据集下载的问题，主要有两种途径： ①直接下载； ②通过提供的API下载。 (1) 直接下载 对于案例中使用的健康相关数据，采用其他用户分享的小米手环记录的步数和睡眠记录。它的网址如下： https：//www．kaggle．com/datasets/damirgadylyaev/morethan4yearsofstepsandsleepdatamiband。进入页面，可以看到数据的分享者及数据介绍，如图54所示。 图54Fitness tracker data 页面介绍 该页面给出了直接的下载链接，这种数据直接单击下载即可。 开源的手环数据相对较少，在Kaggle平台上搜索到还有另一个google data analytics项目，创建者分享了包括Fitbit、小米手环等数据，具体包含活动、心率、步数、睡眠等详细信息，如图55所示。 图55其他健康数据 (2) 通过API下载 有些数据集没有提供直接下载的按钮，只提供下载的API接口。而且一般都是在Python下对Kaggle上的数据集进行处理，下面默认已安装过Python并且可以使用pip进行Python库的安装。 首先，使用pip installl kaggle 语句安装包； 完成后输入命令kaggle compitions list检查是否成功安装kaggle库。 其次，单击“My account”，进去之后，单击“Create New API Token”就可以下载kaggle．json文件了； 把下载的kaggle．json文件放到用户目录下，根据提示Ensure kaggle．json is in the location ～/．kaggle/kaggle．json to use the API．，下载的kaggle．json文件要放到用户目录下的隐藏文件．kaggle文件夹下。如果安装完kaggle之后是没有看到这个文件夹，就手动创建一下即可。 然后直接在命令行下输入下面的命令即可下载数据集。 kaggle datasets download d dataname 5．1．4案例： 健康数据获取与可视化 利用Kaggle上的数据集服务，通过网站链接的方式下载了小米手环记录的步数和睡眠记录，保存文件命名为Steps．csv。该数据集包含了2454条2016年4月27日—2023年1月14日的健康数据集，每一条数据均包括日期(date)、步数(steps)、距离(distance)、跑步距离(runDistance)和卡路里(calories)，数据的分布情况如图56所示。本节的可视化方法数据集均使用“．/5．1．4/Steps．csv”。 图56数据集中的数据分布情况 数据可视化有众多展现方式，不同的数据类型要选择适合的展现方法。常见的可视化图表类型包括： 直方图、柱状图、条形图、折线图、饼图、散点图和箱形图。 1． 直方图 直方图，又称作质量分布图，它是由一系列高度不等的纵向条纹或线段表示数据分布的情况，一般用横轴表示数据的类型，纵轴表示分布情况。直方图可以利用方块的高度来反映数据的差异,只适用于中小规模的数据集，不适用于大规模的数据集。 直方图主要应用在定量数据的可视化场景中，或者用来进行连续型数据的可视化展示。比如，公共英语考试分数的区间分布、抽样调查中的人均寿命的分布特征以及居民可支配收入的分布特征。 为了构建直方图，第一步是将值的范围分段，即将整个值的范围分成一系列间隔，然后计算每个间隔中有多少值。这些值通常被指定为连续的、不重叠的变量间隔。间隔必须相邻，并且通常是相等的大小。代码如下所示。 针对Steps．csv数据集构建的直方图如图57所示。 1.import pandas as pd 2.import matplotlib.pyplot as plt 3.df = pd.read_csv('Steps.csv', header=None) 4.data = df.iloc［:, :2］ 5.df = pd.DataFrame(data) 6.#取steps列的数据 7.# 将列转换为数值型 8.df［1］ = pd.to_numeric(df［1］, errors='coerce') 9.# 绘制直方图 10.plt.hist(df［1］, bins=10, edgecolor='black') 11.# 设置图形标题和坐标轴标签 12.plt.title('Steps Distribution') 13.plt.xlabel('Steps') 14.plt.ylabel('Frequency') 15.# 给每个柱形加上数量标签 16.for rect in plt.gca().patches: 17.x = rect.get_x() + rect.get_width() / 2 18.y = rect.get_height() 19.plt.text(x, y, f'{int(y)}', ha='center', va='bottom') 20.# 设置横轴的显示范围增大 21.plt.xlim(df［1］.min()-10, df［1］.max()+10) 22.# 显示图形 23.plt.show() 图57直方图统计步数分布结果 2． 柱状图 柱状图，是实际工作中最常使用的图表类型之一。它通过垂直的条形展示维度字段的分布情况，直观地反映一段时间内各项数据的变化，在数据统计和销售报表中被广泛应用。 柱状图主要应用在定性数据的可视化场景中，或者离散型数据的分布展示。例如，一个本科班级的学生的籍贯分布，出国旅游人士的职业分布以及下载一款APP产品的操作系统的分布。 直方图与柱状图的区别： 一方面，直方图和柱状图在展示效果上是非常类似的，只是直方图描述的是连续型数据的分布，柱状图描述的是离散型数据的分布，也可以讲： 一个是描述定量数据； 另一个是描述定性数据。另一方面，从图形展示效果来看，柱状图的柱体之间有空隙，直方图的柱体之间没有空隙。代码如下所示，柱状图的结果如图58所示。 24.import pandas as pd 25.import matplotlib.pyplot as plt 26.df = pd.read_csv('Steps.csv') 27.data = df.iloc［:20, :2］ 28.df = pd.DataFrame(data) 29.# 绘制柱状图 30.plt.bar(df［'date'］, df［'steps'］, width=0.8, edgecolor='black') 31.# 设置图形标题和坐标轴标签 32.plt.title('Steps Distribution') 33.plt.xlabel('Date') 34.plt.ylabel('Steps') 35.# 给每个柱体加上数量标签 36.for i, v in enumerate(df［'steps'］): 37.plt.text(i, v + 100, str(v), ha='center', va='bottom',fontsize=8) 38.# 设置横轴标签倾斜显示以避免重叠 39.plt.xticks(rotation=80) 40.# 调整图形尺寸以适应横轴标签 41.plt.tight_layout() 42.# 显示图形 43.plt.show() 图58柱状图统计步数分布结果 3． 条形图 条形图，与柱形图类似，几乎可以表达相同多的数据信息。在条形图中，用宽度相同的条形的高度或者长短来表示数据的多少。通过条形的长短，可以比较不同组别数据分布的差异情况。 与柱状图不同的是条形图主要突出数值的差异，而淡化时间的差异。尤其在项目名称较长以及数量较多时，采用条形图可视化数据会更加美观、清晰。条形图的展示类型与样式与柱状图类似。代码如下所示，条形图结果如图59所示。 44.import pandas as pd 45.import matplotlib.pyplot as plt 46.df = pd.read_csv('Steps.csv') 47.data = df.iloc［:20, :2］ 48.df = pd.DataFrame(data) 49.# 绘制水平条形图 50.plt.barh(df［'date'］, df［'steps'］, height=0.8, edgecolor='black') 51.# 设置图形标题和坐标轴标签 52.plt.title('Steps Distribution') 53.plt.xlabel('Steps') 54.plt.ylabel('Date') 55.# 给每个柱体加上数量标签 56.for i, v in enumerate(df［'steps'］): 57.plt.text(v + 100, i, str(v), ha='left', va='center', fontsize=8) 58.# 调整图形尺寸以适应纵轴标签 59.plt.tight_layout() 60.# 显示图形 61.plt.show() 图59医疗卫生机构水平条形图 4． 折线图 折线图，是用直线段将各数据点连接起来而组成的图形，以折线的方式显示数据的变化趋势。折线图主要用来表示数据的连续性和变化趋势，也可以显示相同的时间间隔内数据的预测趋势。强调的是数据的时间性和变动率，而不是变量。 要绘制折线图，先在笛卡儿坐标系上定出数据点，然后用直线把这些点连接起来。折线图主要应用于时间序列数据的可视化，适合二维的大数据集，尤其那些趋势比单个数据点更重要的数据。代码如下所示，折线图如图510所示。 62.import pandas as pd 63.import matplotlib.pyplot as plt 64.df = pd.read_csv('Steps.csv') 65.data = df.iloc［:20, :2］ 66.df = pd.DataFrame(data) 67.# 绘制折线图 68.plt.plot(df［'date'］, df［'steps'］, marker='o', linestyle='-', color='b') 69.# 设置图形标题和坐标轴标签 70.plt.title('Steps Distribution') 71.plt.xlabel('Date') 72.plt.ylabel('Steps') 73.# 给每个点添加数量标签 74.for i, v in enumerate(df［'steps'］): 75.plt.text(df［'date'］［i］, v + 100, str(v), ha='center', va='bottom', fontsize=7) 76.# 设置横轴标签倾斜显示以避免重叠 77.plt.xticks(rotation=80) 78.# 调整图形尺寸以适应横轴标签 79.plt.tight_layout() 80.# 显示图形 81.plt.show() 图510折线图统计步数分布 5． 饼图 饼图，可以显示一个数据序列中各项的大小与各项总和的比例，每个数据序列具有唯一的颜色或图形，并且与图例中的颜色是相对应的。饼图可以很清晰地反映出各数据系列的百分比情况。 饼图主要应用在定性数据的可视化场景中，或者是用来进行离散型数据的比例展示。如果需要展示参加硕士研究生考试的性别比例、某市一年中四季使用天然气用量的比重以及家庭生活开支用途的比例分布，这些场景都可以使用饼图进行数据的可视化，通过绘制饼图，就可以直观地反映研究对象定性数据的比例分布情况。 在绘制饼图前一定要注意把多个类别按一定的规则排序，推荐将饼图的最大占比部分放置在钟表的12点位置的右边，以强调其重要性。再将第二大占比部分设置在12点位置的左边，剩余的类别则按逆时针方向放置。代码如下所示，饼图如图511所示。 82.import pandas as pd 83.import matplotlib.pyplot as plt 84.import calendar 85.df = pd.read_csv('Steps.csv') 86.data = df.iloc［:, :2］ 87.df = pd.DataFrame(data) 88.# 提取月份信息 89.df［'month'］ = pd.to_datetime(df［'date'］).dt.month 90.# 将月份数字转换为英文简写 91.df［'month'］ = df［'month'］.apply(lambda x: calendar.month_abbr［x］) 92.# 按月份分组，并计算每个月的步数总和 93.monthly_steps = df.groupby('month')［'steps'］.sum() 94.# 绘制饼图 95.plt.pie(monthly_steps, labels=monthly_steps.index, autopct='%.1f%%') 96.# 设置图形标题 97.plt.title('Steps Distribution by Month') 98.# 显示图形 99.plt.show() 图511饼图统计步数分布 6. 散点图 散点图，是指数据点在直角坐标系平面上的分布图，通常用于比较跨类别的数据。散点图包含的数据点越多，比较的效果就会越好。散点图中每个坐标点的位置是由变量的值决定的，用于表示因变量随自变量而变化的大致趋势，以判断两种变量的关系与相关性。散点图可以提供3类关键信息： ①变量之间是否存在数量关联趋势； ②如果存在关联趋势，那么是线性还是非线性的； ③观察是否存在离群值，从而分析这些离群值对建模分析的影响。 散点图类似于折线图，它可以显示单个或者多个数据系列的数据在某时间间隔下的变化趋势。通常用于科学数据的表达、实验数据的拟合和趋势的预测等。代码如下所示，散点图如图512所示。 100. import pandas as pd 101. import matplotlib.pyplot as plt 102. df = pd.read_csv('Steps.csv') 103. data = df.iloc［:20, :2］ 104. df = pd.DataFrame(data) 105. # 绘制散点图 106. plt.scatter(df［'date'］, df［'steps'］) 107. # 设置横轴和纵轴标签 108. plt.xlabel('Date') 109. plt.ylabel('Steps') 110. # 设置标题 111. plt.title('Steps by Date') 112. # 旋转横轴刻度标签，以便更好地显示日期 113. plt.xticks(rotation=45) 114. # 添加数字标签 115. for i, row in df.iterrows(): 116. plt.annotate(row［'steps'］, (row［'date'］, row［'steps'］) ,fontsize=6) 117. # 显示图形 118. plt.show() 图512散点图统计步数分布 7. 箱形图 箱形图，又称为盒须图、盒式图或箱线图，能显示出一组数据的最大值、最小值、中位数、及上下四分位数，可以用来反映一组或多组连续型定量数据分布的中心位置和散布范围。 箱形图由一个箱体和一对箱须所组成，箱体由第一四分位数、中位数(第二四分位数)和第三四分位数所组成。在箱须的末端之外的数值可以理解成离群值，因此，箱须是对一组数据范围的大致直观描述。 箱形图主要应用在一系列测量或观测数据的比较场景中，例如，学校间或班级间测试成绩的比较，球队中的队员体能对比，产品优化前后的测试数据比较以及同类产品的各项性能的比较等，都可以借助箱形图来完成相关分析或研究任务。因此，箱形图的应用范围非常广泛，而且实现起来也非常简单。代码如下所示，箱形图如图513所示。 119. import pandas as pd 120. import matplotlib.pyplot as plt 121. df = pd.read_csv('Steps.csv') 122. # 提取需要绘制箱形图的列 123. columns_to_plot = ［'steps', 'distance', 'runDistance', 'calories'］ 124. # 绘制箱形图 125. plt.boxplot(df［columns_to_plot］.values) 126. # 设置横轴标签 127. plt.xticks(range(1, len(columns_to_plot) + 1), columns_to_plot) 128. # 设置纵轴标签 129. plt.ylabel('Value') 130. # 设置标题 131. plt.title('Boxplot of Activity Metrics') 132. # 显示图形 133. plt.show() 图513箱形图展示运动健康数据分布情况 5．2移动健康数据可视化大屏设计 数据可视化是指将数据以图表的形式表示，并利用数据分析和开发工具发现其中未知信息的处理过程。使用可视化工具对数据进行可视化有许多优势： (1) 更直观的理解： 可视化将抽象的数据转化为图形、图表和图像，使数据变得更加直观和易于理解。人们通常更容易通过可视化捕捉到数据之间的关系、趋势和模式，而不是从原始数据表格中。 (2) 发现隐藏的信息： 可视化可以揭示数据中的隐藏信息和趋势，帮助用户发现在原始数据中可能被忽略的关键见解。这有助于作出更准确的决策和预测。 (3) 交互性： 可视化工具通常提供交互式功能，允许用户探索数据，根据需求放大、缩小、筛选和排序。这种交互性能够使用户更深入地探索数据，并且让用户可以根据兴趣进行个性化的分析。 (4) 有效的沟通工具： 可视化可以将复杂的数据和分析结果以简洁的方式传达给非专业人士。这对于向非技术人员、利益相关者或团队成员传递信息和见解非常有帮助。 (5) 快速的洞察力： 可视化工具能够快速生成图表和图像，使数据分析变得高效。用户可以快速地创建多种类型的图表，以便更快地获取洞察力。 (6) 跨数据源比较： 如果您拥有来自不同来源的数据，可视化可以将它们融合到一个图表或图形中，以便进行比较和分析。这有助于发现不同数据源之间的关联性和差异。 (7) 支持决策制定： 可视化工具可以帮助决策者更好地理解问题和机会，从而作出更明智的决策。它们可以将复杂的情况可视化，使决策制定变得更加有根据。 (8) 提高报告和演示质量： 在报告、演示和展示中使用可视化可以提高内容的吸引力和影响力。图表和图像能够更生动地展示信息，使受众更易于记住和理解。 总之，可视化工具能够将数据转化为易于理解和分析的形式，帮助用户更好地理解数据、发现见解并作出更明智的决策。无论是在数据分析、报告制作、教育还是决策制定方面，可视化都是一个强大的工具。对移动健康数据的可视化大屏设计流程如图514所示。 图514可视化大屏设计流程 5．2．1可视化工具库 目前有许多流行的可视化工具库可供选择，用于创建各种类型的数据可视化。其中包含Matplotlib，它是Python中最常用的数据可视化库之一，用于创建静态、交互式和动画图表； Seaborn也是基于Python的库，建立在Matplotlib之上，专注于更美观的统计图表； Pyecharts是Python与ECharts结合的产物，封装了ECharts各类图表的基本操作，然后通过渲染机制，输出一个包含JS代码的HTML文件。 1． Matplotlib Matplotlib是一个非常强大的Python画图工具，使用该工具可以将很多数据通过图表的形式更直观地呈现出来。Matplotlib可以绘制线图、散点图、等高线图、条形图、柱状图、3D 图形，甚至图形动画等各种静态、动态、交互式的图表。要想使用Matplotlib绘制图表，需要先导入绘制图表的模块pyplot，该模块提供了一种类似MATLAB的绘图方式，主要用于绘制简单或复杂的图形。Matplotlib通常的调入形式是import matplotlib．pyplot as plt。 使用pyplot绘图的一般过程： 首先生成或读入数据，然后根据实际需要绘制二维折线图、散点图、柱状图、饼状图、雷达图或三维曲线、曲面、柱状图等，接下来设置坐标轴标签(xlabel、ylabel函数)、坐标轴刻度线(xticks、yticks函数)、图例(legend函数)、标题(title函数)等图形属性，最后显示或保存绘图结果。下面利用Matplotlib工具绘制玫瑰图，所利用的数据集为“．/5．2．1/Steps．csv”，代码如下所示。绘制好的玫瑰图如图515所示。 1.import pandas as pd 2.import matplotlib.pyplot as plt 3.from sklearn.preprocessing import MinMaxScaler 4.import numpy as np 5.df = pd.read_csv('Steps.csv') 6.# 提取需要绘制箱形图的列 7.columns_to_plot = ［'steps', 'distance', 'runDistance', 'calories'］ 8.# 创建MinMaxScaler对象进行归一化 9.scaler = MinMaxScaler() 10.# 归一化数据 11.normalized_values = scaler.fit_transform(df［columns_to_plot］) 12.# 计算每个度数的平均值 13.mean_values = np.mean(normalized_values, axis=0) 14.# 将度数转换为弧度 15.theta = ［i * 2 * np.pi / len(columns_to_plot) for i in range(len(columns_to_plot))］ 16.# 定义颜色映射 17.cmap = plt.get_cmap('rainbow') 18.# 绘制玫瑰图 19.ax = plt.subplot(111, polar=True) 20.bars = ax.bar(theta, mean_values, width=0.4) 21.# 设置每个柱子的颜色和标签 22.for bar, column, angle in zip(bars, columns_to_plot, theta): 23.color = cmap(angle / (2 * np.pi)) 24.bar.set_facecolor(color) 25.bar.set_label(column) 26.# 设置角度标签 27.ax.set_xticks(theta) 28.ax.set_xticklabels(columns_to_plot) 29.# 添加图例 30.ax.legend() 31.# 设置标题 32.plt.title('Rose Plot of Normalized Activity Metrics') 33.# 显示图形 34.plt.show() 图515玫瑰图展示运动健康数据分布情况 从图515可看出，小米手环运动数据集数据的维度较少，玫瑰图不能展示出很好的效果。因此利用5．2．2节中处理好的医疗卫生数据进行维度的增加和图表显示效果的优化，所用到的数据集为“．/5．2．1/all_data．json”，代码如下所示，优化后的玫瑰图如图516所示。 1.# 玫瑰图 2.import json 3.import pandas as pd 4.import numpy as np 5.import matplotlib.pyplot as plt 6.import matplotlib as mpl 7.import json 8.mpl.rcParams［"font.sans-serif"］=［"SimHei"］ # 用来正常显示中文标签 9.mpl.rcParams［"axes.unicode_minus"］=False # 用来正常显示负号 10.def rosetype_pie(country,confirmed,size,colors): 11.num= len(size) # 柱子的数量 12.width = 2 * np.pi / num # 每个柱子的宽度 13.rad = np.cumsum(［width］ * num)# 每个柱子的角度 14.plt.figure(figsize=(6,6),dpi=500)# 创建画布 15.ax = plt.subplot(projection='polar') 16.ax.set_ylim(-1, np.ceil(max(size) + 1))# 中间空白,-1为空白半径大小，可自行调整 17.ax.set_theta_zero_location('N',-5.0)# 设置极坐标的起点方向 W,N,E,S, -5.0为偏离数值，可自行调整 18.ax.set_theta_direction(1) # 1为逆时针，-1为顺时针 19.ax.grid(False)# 不显示极轴 20.ax.spines［'polar'］.set_visible(False)# 不显示极坐标最外的圆形 21.ax.set_yticks(［］)# 不显示坐标间隔 22.ax.set_thetagrids(［］)# 不显示极轴坐标 23.ax.bar(rad, size, width=width, color=colors, alpha=1) # 画图 24.ax.bar(rad, 1, width=width, color='white', alpha=0.15)# 中间添加白色色彩使图案变浅 25.ax.bar(rad, 3, width=width, color='white', alpha=0.1)# 中间添加白色色彩使图案变浅 26.ax.bar(rad, 5, width=width, color='white', alpha=0.05)# 中间添加白色色彩使图案变浅 27.ax.bar(rad, 7, width=width, color='white', alpha=0.03)# 中间添加白色色彩使图案变浅 28.# 设置text 29.for i in np.arange(num): 30.if i < 8: 31.ax.text(rad［i］,# 角度 32.size［i］-0.2,# 长度 33.country［i］+'＼n'+str(confirmed［i］)+'个',# 文本 34.rotation=rad［i］ * 180 / np.pi -5,# 文字角度 35.rotation_mode='anchor', 36.# alpha=0.8,# 透明度 37.fontstyle='normal',# 设置字体类型，可选参数［ 'normal' | 'italic' | 'oblique' ］，italic斜体，oblique倾斜 38.fontweight='black', # 设置字体粗细，可选参数 ［'light', 'normal', 'medium', 'semibold', 'bold', 'heavy', 'black'］ 39.color='white', # 设置字体颜色 40.size=size［i］/4.4, # 设置字体大小 41.ha="center", # 'left','right','center' 42.va="top", # 'top', 'bottom', 'center', 'baseline', 'center_baseline' 43.) 44.elif i < 15: 45.ax.text(rad［i］+0.02, 46.size［i］-0.7, 47.country［i］ + '＼n' + str(confirmed［i］) + '个', 48.fontstyle='normal', 49.fontweight='black', 50.color='white', 51.size=size［i］ / 3.2, 52.ha="center", 53.) 54.else: 55.ax.text(rad［i］, 56.size［i］+0.1, 57.str(confirmed［i］) + '例 ' + country［i］, 58.rotation=rad［i］ * 180 / np.pi + 85, 59.rotation_mode='anchor', 60.fontstyle='normal', 61.fontweight='black', 62.color='black', 63.size=2, 64.ha="left", 65.va="bottom", 66.) 67.plt.title("全国医疗卫生机构数统计情况", size=5) 68.#verticalalignment设置水平对齐方式 ，可选参数 ： 'center' , 'top' , 'bottom' , 'baseline 69.plt.show() 70.if __name__ == '__main__': 71.filename = 'D:＼＼all_data.json'# JSON文件路径 72.with open(filename, 'r', encoding='utf-8') as f: 73.data = json.load(f) 74.words = ［］ 75.for province, province_data in data.items(): 76.for indicator, years_data in province_data.items(): 77.if indicator == "医疗卫生机构数(个)": 78.max_value = max(years_data.values()) 79.max_year = ［year for year, value in years_data.items() if value == max_value］ 80.words.append((province, max_value)) 81.sorted_words = sorted(words, key=lambda x: x［1］, reverse=False)# 根据数据值对柱子进行排序(升序) 82.df = pd.DataFrame(sorted_words, columns=［'省份', '数据'］) 83.country = list(df［'省份'］) 84.confirmed = list(df［'数据'］) 85.# df=pd.read_csv('WHO-COVID-19-global-table-data.csv') 86.# df=df.reset_index() 87.# df=df.drop(0) 88.# df［'name'］=df［'index'］ 89.# df［'nowconfirm'］=df［'Cases - newly reported in last 7 days per 100000 population'］ 90.# df = df.sort_values('nowconfirm',ascending=False).head(30) 91.# world_name = pd.read_excel("中英文对照表.xlsx",engine='openpyxl') 92.# data = pd.merge(df, world_name, left_on="index", right_on="英文", how="inner") 93.# country = list(data［'中文'］) 94.# confirmed = list(data［'nowconfirm'］) 95.colors = ［(0.68359375, 0.02734375, 0.3203125),(0.78125, 0.05078125, 0.2578125),(0.875, 0.0390625, 0.1796875), 96.(0.81640625, 0.06640625, 0.0625),(0.8515625, 0.1484375, 0.08203125),(0.90625, 0.203125, 0.13671875), 97.(0.89453125, 0.2890625, 0.0703125),(0.84375, 0.2421875, 0.03125),(0.9140625, 0.26953125, 0.05078125), 98.(0.85546875, 0.31640625, 0.125),(0.85546875, 0.3671875, 0.1171875),(0.94921875, 0.48046875, 0.28125), 99.(0.9375, 0.51171875, 0.1484375),(0.93359375, 0.59765625, 0.0625),(0.93359375, 0.62890625, 0.14453125), 100. (0.86328125, 0.5859375, 0.15234375),(0.86328125, 0.71875, 0.16015625),(0.86328125, 0.8203125, 0.16015625), 101. (0.76171875, 0.8671875, 0.16015625),(0.53125, 0.85546875, 0.15625),(0.4765625, 0.94140625, 0.0703125), 102. (0.21484375, 0.91015625, 0.0625),(0.15234375, 0.88671875, 0.08203125),(0.11328125, 0.87890625, 0.19921875), 103. (0.11328125, 0.8125, 0.1796875),(0.1875, 0.76953125, 0.2109375),(0.2109375, 0.78125, 0.38671875), 104. (0.1484375, 0.76953125, 0.30859375),(0.22265625, 0.73046875, 0.35546875),(0.2890625, 0.6875, 0.4765625)］ # 转化为小数的rgb色列表 105. size = ［22, 19, 17, 12, 11, 10, 9, 8, 7.2, 7.0, 6.8, 6.6, 6.4, 6.2, 6.0, 106. 5.8, 5.6, 5.4, 5.2, 5.0, 4.8, 4.6, 4.4, 4.2, 4.0, 3.8, 3.6, 3.4, 3.2, 3.0］ # 自定义一个柱长度列 107. rosetype_pie(country, confirmed, size, colors) 图516优化后的玫瑰图效果展示 2． Seaborn Seaborn同Matplotlib一样，也是Python进行数据可视化分析的重要的第三方包。但是在Matplotlib的基础上进行了更高级的API封装，从而使得作图更加容易，在大多数情况下，使用Seaborn能绘制具有吸引力的图表，而使用Matplotlib却能绘制出具有更多特色的图表。应该把Seaborn视为Matplotlib的补充，而不是替代物。Seaborn在Matplotlib的基础上，侧重数据统计分析图表的绘制，包括带误差线的柱形图、散点图、箱形图、小提琴图、一维和二维的统计直方图和核密度估计图等。Seaborn的默认导入语句为import seaborn as sns。接下来利用小米手环运动数据集，即“．/5．2．1/Steps．csv”进行小提琴图的绘制，代码如下所示，小提琴图的绘制结果如图517所示。 1.import pandas as pd 2.import matplotlib.pyplot as plt 3.import seaborn as sns 4.from sklearn.preprocessing import MinMaxScaler 5.df = pd.read_csv('Steps.csv') 6.# 提取需要绘制小提琴图的列 7.columns_to_plot = ［'steps', 'distance', 'runDistance', 'calories'］ 8.# 创建MinMaxScaler对象进行归一化 9.scaler = MinMaxScaler() 10.normalized_values = scaler.fit_transform(df［columns_to_plot］) 11.# 将归一化后的数据转换回DataFrame 12.normalized_df = pd.DataFrame(normalized_values, columns=columns_to_plot) 13.# 绘制小提琴图 14.sns.violinplot(data=normalized_df,width=1) 15.# 设置标题和坐标轴标签 16.plt.title('Normalized Violin Plot of Activity Metrics') 17.plt.xlabel('Activity') 18.plt.ylabel('Normalized Value') 19.# 显示图形 20.plt.show() 图517小提琴图显示运动健康数据分布情况 3． Pyecharts Pyecharts是一个用于创建交互式图表的 Python 库，它基于 ECharts(百度开发的一个强大的 JavaScript 图表库)开发而来。ECharts 可以生成各种类型的图表，包括折线图、柱状图、饼图、散点图等，并支持动态数据更新、数据联动、数据可视化等特性。Pyecharts通过将 Python 数据转换为 ECharts 所需的 JSON 格式来创建图表。它提供了一组简单的 API，使用户能够轻松地创建各种图表，而无需深入了解 JavaScript。Pyecharts提供了一种在Python中创建交互式数据可视化图表的方便方式，适用于数据分析、报告制作、演示等多种应用场景。接下来利用小米手环运动数据集，即“．/5．2．1/Steps．csv”进行图表绘制，代码如下所示，其中用到了grid函数对图标进行组合显示，组合图的绘制结果如图518所示。 1.import pandas as pd 2.from pyecharts.charts import Line, Bar 3.from pyecharts import options as opts 4.from pyecharts.globals import ThemeType 5.from pyecharts.charts import Grid 6.# 读取CSV文件 7.df = pd.read_csv('Steps.csv') 8.# 提取数据，截断时间至2016年 9.df［'date'］ = pd.to_datetime(df［'date'］) 10.df = df［df［'date'］.dt.year <= 2016］ 11.x_data = df［'date'］ 12.y_data = df［'steps'］ 13.# 折线图 14.line = ( 15.Line(init_opts=opts.InitOpts(theme=ThemeType.LIGHT)) 16..add_xaxis(x_data.dt.strftime('%Y-%m-%d').tolist())# 格式化日期为年月日 17..add_yaxis("折线图步数", y_data.tolist(), itemstyle_opts=opts.ItemStyleOpts(color="blue")) 18..set_series_opts(label_opts=opts.LabelOpts(is_show=False)) 19..set_global_opts(legend_opts=opts.LegendOpts(pos_left="10%"))# 设置折线图图例位置 20.) 21.# 柱状图 22.bar = ( 23.Bar(init_opts=opts.InitOpts(theme=ThemeType.LIGHT)) 24..add_xaxis(x_data.dt.strftime('%Y-%m-%d').tolist())# 格式化日期为年月日 25..add_yaxis("柱状图步数", y_data.tolist(), itemstyle_opts=opts.ItemStyleOpts(color="green")) 26..set_series_opts(label_opts=opts.LabelOpts(is_show=False)) 27..set_global_opts(legend_opts=opts.LegendOpts(pos_left="35%"))# 设置柱状图图例位置 28.) 29.# 使用 Grid 组合折线图和柱状图 30.grid = ( 31.Grid() 32..add(bar, grid_opts=opts.GridOpts(pos_bottom="65%", pos_left="70%",pos_right="65%")) 33..add(line, grid_opts=opts.GridOpts(pos_left="15%")) 34.) 35.# 渲染图表 36.grid.render_notebook() 图518利用Pyecharts实现组合图显示 5．2．2案例： 搭建医疗卫生数据可视化大屏 本节中将利用Pyecharts框架实现医疗卫生数据的大屏可视化，数据来源为https：//data．stats．gov．cn/easyquery．htm?cn=E0103，单击“卫生”→“医疗卫生机构”，下载最近20年中国各省市的医疗卫生机构数据，存入名为country_data的文件夹中。经过数据预处理后，保存处理好的json文件为all_data．json。上述数据集的位置为“．/5．2．2/all_data．json”，接下来利用Pyecharts框架实现可视化大屏，详细过程如下所述。 1． 数据预处理 将下载好的数据经过数据预处理存为JSON文件的格式，命名为all_data．json，便于后期画图的使用，代码如下所示，JSON文件结构示例如图519所示。 1.import pandas as pd 2.import numpy as np 3.import json 4.import os 5.# 存储所有数据的字典 6.all_data = {} 7.# 数据文件夹路径 8.data_folder = r"country_data" 9.# 遍历所有的XLS格式文件 10.for filename in os.listdir(data_folder): 11.if filename.endswith('.xls'): 12.# 读取XLS格式文件 13.file_path = os.path.join(data_folder, filename) 14.df = pd.read_excel(file_path, header=None) 15.# print(df) 16.# 获取地区信息(第2行) 17.region_info = str(df.iloc［1, 0］) 18.# print(region_info) 19.# 提取地区名称 20.region = region_info.split("：")［1］.strip() 21.# 提取需要的数据(从第5行开始，指标名称在第一列，年份在后续列) 22.data = {} 23.for row in range(4, 20):# 只处理前20行数据 24.indicator_name = df.iloc［row, 0］ 25.years_data = df.iloc［row, 1:］.fillna(0).tolist()# 将NaN值替换为0 26.data［indicator_name］ = dict(zip(df.iloc［3, 1:］.tolist(), years_data)) 27.# 更新总数据字典 28.all_data［region］ = data 29.# 保存为JSON文件 30.output_file_path = "all_data.json"# 修改为您想要保存的JSON文件路径 31.with open(output_file_path, "w", encoding="utf-8") as f: 32.json.dump(all_data, f, ensure_ascii=False, indent=4) 33.# 读取JSON文件 34.filename = 'all_data.json'# JSON文件路径 35.with open(filename, 'r', encoding='utf-8') as f: 36.data = json.load(f) 37.# 修改数据 38.data［"广西"］ = data.pop("广西壮族自治区") 39.data［"西藏"］ = data.pop("西藏自治区") 40.data［"新疆"］ = data.pop("新疆维吾尔自治区") 41.# 保存回文件 42.with open(filename, 'w', encoding='utf-8') as f: 43.json.dump(data, f, ensure_ascii=False) 图519JSON文件结构示例 2． 柱状图 创建柱状图如图520所示，绘制方法是先通过对每个省市的所有指标值求和，选出值最大的省市，即河北省的各级医疗卫生机构不同年份的统计情况，在本节中为了显示更加美观，只选取了最近六年的数据进行展示。 该柱状图中工具箱包含“保存为图片”“还原”“数据视图”“区域缩放”“区域缩放还原”“切换为折线图”“切换为柱状图”“切换为堆叠”等，可以单击柱状图下方的label图标，图标显示色彩和显示空白分别可以实现“选择展示”和“不选择展示”的效果，柱状图还可以通过鼠标拖拉进行收缩。代码如下所示。 1.def bar(): 2.# 读取JSON文件 3.filename = ' all_data.json'# JSON文件路径 4.with open(filename, 'r', encoding='utf-8') as f: 5.data = json.loads(f.read()) 6.# 获取所有地区 7.regions = list(data.keys()) 8.#指标映射 9.indicator_mapping = { 10.'医疗卫生机构数': '医疗卫生机构数(个)', 11.'医院数': '医院数(个)', 12.'综合医院数': '综合医院数(个)', 13.'中医医院数': '中医医院数(个)', 14.'专科医院数': '专科医院数(个)', 15.'基层医疗卫生机构': '基层医疗卫生机构(个)', 16.'社区卫生服务中心(站)数': '社区卫生服务中心(站)数(个)', 17.'街道卫生院数': '街道卫生院数(个)', 18.'乡镇卫生院数': '乡镇卫生院数(个)', 19.'村卫生室数': '村卫生室数(个)', 20.'门诊部(所)数': '门诊部(所)数(个)', 21.'专业公共卫生机构数': '专业公共卫生机构数(个)', 22.'疾病预防控制中心数': '疾病预防控制中心数(个)', 23.'专科疾病防治院(所/站)数': '专科疾病防治院(所/站)数(个)', 24.'妇幼保健院(所/站)数': '妇幼保健院(所/站)数(个)', 25.'卫生监督所(中心)数': '卫生监督所(中心)数(个)' 26.} 27.# 按照每个省份所有指标值之和的准则选择地区 28.max_sum = 0# 最大和初始化为0 29.selected_region = ''# 初始化选中的地区为空字符串 30.for region in regions: 31.region_sum = sum(sum(data［region］［key］.values()) for key in indicator_mapping.values()) 32.if region_sum > max_sum: 33.max_sum = region_sum 34.selected_region = region 35.# 输出选中的地区 36.# print("选中的地区：", selected_region) 37.years = ［"2003年", "2004年", "2005年", "2006年", "2007年", "2008年", "2009年", "2010年", "2011年", 38. "2012年", "2013年", "2014年", "2015年", "2016年", "2017年", "2018年", "2019年", "2020年", "2021年"］ 39.years = years［-6:］# 只保留最后6个年份 40.x_data = years 41.y_data_bar = ［］ 42.y_data_line = ［］ 43.for indicator, key in indicator_mapping.items(): 44.values_bar = ［］ 45.values_line = ［］ 46.for year in years: 47.try: 48.value = data［selected_region］［key］［year］ 49.except KeyError: 50.value = 0 51.values_bar.append(value) 52.values_line.append(round(value / 100, 2))# 将值除以100，并保留2位小数 53.y_data_bar.append(values_bar) 54.y_data_line.append(values_line) 55.# 创建图表 56.bar_chart = ( 57.Bar(init_opts=opts.InitOpts(theme=ThemeType.LIGHT)) 58..add_xaxis(x_data) 59..set_global_opts( 60.title_opts=opts.TitleOpts(title=f"{selected_region}的医疗卫生机构统计", pos_top="1%"),# 设置柱状图标题为选中地区的名称 61.legend_opts=opts.LegendOpts(pos_top="85%",pos_left="center", orient="horizontal",item_width=8, item_height=8, border_width=0), 62.toolbox_opts=opts.ToolboxOpts( 63.orient="horizontal", 64.pos_top="5%", 65.pos_left="40%", 66.# pos_right="10%" 67.item_size=15# 设置工具箱图标尺寸为14 68.), 69.datazoom_opts=［opts.DataZoomOpts(type_="inside", range_start=0, range_end=100)］, 70.) 71..set_series_opts(label_opts=opts.LabelOpts(is_show=False)) 72.) 73.# 添加每个指标的数据到图中 74.for i, indicator in enumerate(indicator_mapping.keys()): 75.bar_chart.add_yaxis(indicator, y_data_bar［i］, stack=f"stack_{i+1}") 76.return bar_chart 图520柱状图结果显示医疗卫生机构的统计情况 3． 饼图 创建饼图如图521所示，绘制方法是先计算“医疗卫生机构数(个)”单个指标历年的全国各省市数据的总和，按照10年为周期划分为一个双层饼图，在饼图中单击图标后分别呈现彩色和白色可以实现“选择展示”和“选择不展示”的效果。代码如下所示。 1.def calculate_national_total(data): 2.indicator_name = '医疗卫生机构数(个)' 3.national_total = {} 4.for region_data in data.values(): 5.for year, value in region_data［indicator_name］.items(): 6.if year not in national_total: 7.national_total［year］ = 0 8.national_total［year］ += value 9.return {'全国': {indicator_name: national_total}} 10.def create_double_layer_pie(data): 11.indicator_name = '医疗卫生机构数(个)' 12.region_data = data［'全国'］［indicator_name］ 13.years = list(region_data.keys()) 14.legend_opts = opts.LegendOpts(pos_bottom="bottom", border_width=0,item_width=8, item_height=8,pos_top="85%") 15.pie = ( 16.Pie() 17..set_global_opts( 18.title_opts=opts.TitleOpts( 19.title=f"{indicator_name}的双层饼图", 20.pos_top="top" 21.), 22.legend_opts=legend_opts 23.) 24..set_series_opts(label_opts=opts.LabelOpts(formatter="{b}: {d}%")) 25.) 26.outer_radius = "75%"#设置饼图显示半径 27.inner_radius = "60%" 28.for i in range(0, len(years), 10): 29.start_year = years［i］ 30.end_year = years［i + 9］ if i + 9 < len(years) else years［-1］ 31.label = f"{start_year} - {end_year}" 32.values = list(region_data.values())［i:i + 10］ 33.values.reverse() 34.pie.add( 35.series_name=label, 36.data_pair=［(year, value) for year, value in zip(years［i:i + 10］, values)］, 37.radius=［inner_radius, outer_radius］ 38.) 39.inner_radius = str(int(inner_radius［:-1］) - 10) + "%" 40.outer_radius = str(int(outer_radius［:-1］) - 10) + "%" 41.return pie 42.def pie(): 43.# 读取 JSON 文件 44.filename = ' all_data.json'# JSON文件路径 45.with open(filename, 'r', encoding='utf-8') as f: 46.data = json.loads(f.read()) 47.# 计算全国数据总和 48.data1 = calculate_national_total(data) 49.# 生成双层饼图 50.chart = create_double_layer_pie(data1) 51.return chart 图521饼图结果显示全国每年的医疗卫生机构分布情况 4． 热图 创建热图的方法是先计算全国各省市历年数据的总和，然后显示针对每个省市的数量分布，该热图可以利用鼠标滚轴实现放大或者缩小区域的功能,代码如下所示，热图显示结果。 1.def heat(): 2.# 读取JSON文件 3.filename = ' all_data.json'# JSON文件路径 4.with open(filename, 'r', encoding='utf-8') as f: 5.data = json.load(f) 6.# 构造地区和数值的列表 7.region_list = ［］ 8.value_list = ［］ 9.for region, region_data in data.items(): 10.region_list.append(region) 11.value = sum(［sum(years_data.values()) for years_data in region_data.values()］) 12.value_list.append(value) 13.# 创建Geo实例并添加数据 14.heat = ( 15.Geo() 16..add_schema(maptype="china") 17..add( 18."地区数据", 19.［list(z) for z in zip(region_list, value_list)］, 20.type_="heatmap", 21.label_opts=opts.LabelOpts(formatter="{b}: {c}"), 22.) 23..set_series_opts(label_opts=opts.LabelOpts(is_show=True)) 24..set_global_opts(visualmap_opts=opts.VisualMapOpts(), title_opts=opts.TitleOpts(title="中国地区数据")) 25.) 26.return heat 5． 词图 创建词图如图522所示，该图是针对“医疗卫生机构数(个)”单个指标在各省市的历年数据最大值的展示效果。代码如下所示。 1.def word(): 2.def create_word_cloud(data): 3.words = ［］ 4.for province, province_data in data.items(): 5.for indicator, years_data in province_data.items(): 6.if indicator == "医疗卫生机构数(个)": 7.max_value = max(years_data.values()) 8.# print(max_value) 9.max_year = ［year for year, value in years_data.items() if value == max_value］ 10.# 使用 f-string 格式化字符串 11.# words.append((province, f"{max_year［0］} :{max_value}")) 12.words.append((province, max_value)) 13.# print(words) 14.wordcloud = ( 15.WordCloud() 16..add("", words, word_size_range=［10, 50］)#设置词的显示大小，进而控制画布上显示词语的数量 17..set_global_opts(title_opts=opts.TitleOpts(title="省份医疗卫生机构数词云图", pos_top="top", pos_left="left")) 18.) 19.return wordcloud 20.# 读取JSON文件 21.filename = 'all_data.json'# JSON文件路径 22.with open(filename, 'r', encoding='utf-8') as f: 23.data = json.load(f) 24.chart = create_word_cloud(data) 25.return chart 图522词图显示省市医疗卫生机构数量分布 6． 大屏格式分布设置 设置大屏的标题显示。代码如下。 1.def title(name,color): #标题 2.c = (Pie(). 3.set_global_opts( 4.title_opts=opts.TitleOpts(title=name,pos_left='center',pos_top='center', 5.title_textstyle_opts=opts.TextStyleOpts(color=color,font_size=25)))) 6.return c 利用page．add方法将各个子图集成在一张画布上显示，但不设置显示格式。代码如下。 1.from pyecharts.charts import Geo, WordCloud 2.from pyecharts.globals import ThemeType 3.from pyecharts import options as opts 4.from pyecharts.faker import Faker 5.from pyecharts.render import make_snapshot 6.from pyecharts.globals import ThemeType 7.from snapshot_selenium import snapshot as driver 8.from pyecharts.charts import Page 9.# 创建一个空白的 Page 页面 10.page = Page() 11.page.add( 12.title('医疗卫生机构数据可视化大屏', color='red'), 13.heat(), 14.pie(), 15.bar(), 16.word() 17.) 18.# 渲染为 HTML 字符串 19.html_content = page.render_embed() 20.# 添加 CSS 样式，为整个页面加边框 21.styled_html_content = f""" 22. 23. 24. 25. 37. 38. 39.
40.{html_content} 41.
42. 43. 44.""" 45.# 将 HTML 内容保存到文件中 46.with open("test.html", "w", encoding="utf-8") as f: 47.f.write(html_content) 调整显示格式： 通过调整div元素的样式调整子图的布局，使大屏的各个子图和子元素在画布上合理分布。代码如下。 1.from bs4 import BeautifulSoup 2.# 读取 HTML 文件并解析 3.with open("test.html", "r+", encoding='utf-8') as html: 4.html_bf = BeautifulSoup(html, 'lxml') 5.# 添加样式 6.style_tag = html_bf.new_tag('style') 7.style_tag.string = ".chart-container { background-color: black; }" 8.html_bf.head.append(style_tag) 9.# 获取所有class为chart-container的div元素 10.divs = html_bf.select('.chart-container') 11. # 修改第一个div的样式(标题) 12.divs［0］［'style'］ = "width:100%;height:10%;position:absolute;top:0;left:0;border-style:solid;border-color:#444444;border-width:0px;" 13.# 修改第二个div的样式(左上角) 14.divs［1］［"style"］ = "width:50%;height:50%;position:absolute;top:10%;left:0;border-style:solid;border-color:#444444;border-width:0px;" 15.# 修改第三个div的样式(右上角) 16.divs［2］［"style"］ = "width:50%;height:40%;position:absolute;top:10%;right:0;border-style:solid;border-color:#444444;border-width:0px;" 17.# 修改第四个div的样式(左下角) 18.divs［3］［"style"］ = "width:50%;height:40%;position:absolute;bottom:0;left:0;border-style:solid;border-color:#444444;border-width:0px;" 19.# 修改第五个div的样式(右下角) 20.divs［4］［"style"］ = "width:50%;height:50%;position:absolute;bottom:0;right:0;border-style:solid;border-color:#444444;border-width:0px;" 21.# 将修改后的HTML写回文件 22.with open("test.html", "w", encoding='utf-8') as html: 23.html.write(str(html_bf)) 大屏制作过程中所用到的依赖的总结补充代码如下。 1.import pandas as pd 2.import numpy as np 3.import json 4.import os 5.from pyecharts.charts import WordCloud,Bar, Line, Page,Pie,Geo 6.from pyecharts import options as opts 7.from pyecharts.commons.utils import JsCode 8.from pyecharts.globals import ThemeType 9.from pyecharts.render import make_snapshot 调整完的可视化大屏的显示效果如图523所示。 图523综合效果图 5．3小米手环步态数据分析 基于下载好的小米手环步态数据,利用时间序列方法进行分析，主要通过自回归积分滑动平均模型(autoregressive integrated moving average model, ARIMA)和长短期记忆网络(long shortterm memory, LSTM)对时序数据进行可视化、平稳性检验以及模型构建，最终实现预测。 5．3．1案例： ARIMA模型分析数据 1． ARIMA模型原理 ARIMA是一个时间序列分析方法，被广泛应用于时间序列数据的预测和建模。ARIMA模型根据原序列是否平稳以及回归中所含部分的不同，包括移动平均过程(MA)、自回归过程(AR)、自回归移动平均过程(ARMA)以及ARIMA过程。ARIMA模型的基本原理如式(51)所示。 ARIMA(p,d,q)=AR(p)+I(d)+MA(q)(51) 式中，AR(p)表示自回归模型，p为自回归阶数； I(d)表示差分模型，d为时间序列成为平稳时所做的差分次数； MA(q)表示移动平均模型,q为移动平均阶数。 自回归： ARIMA模型基于自回归，即当前时间点的值与前面若干时间点的值有关。自回归阶数p表示当前时间点与前面p个时间点的值有关。 差分： 为了消除时间序列数据的非平稳性，ARIMA模型通常需要进行差分操作，即将原始数据转换为差分数据，消除趋势和季节性等影响。差分阶数d表示需要对时间序列数据进行差分的次数。 移动平均： ARIMA模型基于移动平均，即当前时间点的值与前面若干时间点的误差有关。移动平均阶数q表示当前时间点与前面q个时间点的误差有关。 ARIMA模型可以通过对时间序列数据进行分析和拟合，估计出合适的模型参数，从而进行数据预测和建模。 2． 实验过程 ARIMA模型预测的基本程序包括以下步骤： (1) 根据时间序列的散点图、自相关函数(autocorrelation function，ACF)图和偏自相关函数(partial autocorrelation function，PACF)图以单位根检验(augmented dickeyfuller, ADF)其方差、趋势及其季节性变化规律，对序列的平稳性进行识别。 (2) 对非平稳序列进行平稳化处理。如果数据序列是非平稳的，并存在一定的增长或下降趋势，则需要对数据进行差分处理; 如果数据存在异方差，则需对数据进行技术处理，直到处理后的数据的自相关函数值和偏相关函数值无显著地异于零。 (3) 根据时间序列模型的识别规则，建立相应的模型。若平稳序列的PACF是截尾的，而ACF是拖尾的，可断定序列适合AR模型; 若平稳序列的PACF是拖尾的，而ACF是截尾的，则可断定序列适合MA模型; 若平稳序列的PACF和ACF均是拖尾的，则序列适合ARMA模型(截尾是指时间序列的ACF或PACF在某阶后均为0的性质; 拖尾是ACF或PACF并不在某阶后均为0的性质)。 (4) 进行参数估计，检验是否具有统计意义。 (5) 进行假设检验，诊断残差序列是否为白噪声。 (6) 利用已通过检验的模型进行预测分析。 接下来是利用ARIMA模型分析小米手环步态数据的详细过程。 导入分析所需要的包，代码如下： 1.import pandas as pd 2.import datetime 3.import math 4.import numpy as np 5.import matplotlib.pylab as plt 6.from matplotlib.pylab import style 7.from scipy.special import logsumexp 8.import statsmodels.tsa.api as smtsa 9.from statsmodels.graphics.tsaplots import plot_acf, plot_pacf 10.from statsmodels.tsa.stattools import adfuller as ADF 11.from sklearn.metrics import mean_squared_error as mse, mean_absolute_error as mae 数据读取和预览，代码如下，结果如图524所示。 1.steps_df=pd.read_csv("Steps.csv",index_col = 0,parse_dates=［0］) 2.#steps_df 3.plt.plot(steps_df［'runDistance'］) 4.plt.title('Daily runDistance') 5.plt.show() 图524跑步距离的统计显示 数据预处理，缺失数据填充，代码如下，结果如图525所示。 1.#输出数据缺失值填充之前的数据 2.print(steps_df.runDistance［'20160427':'20230114'］) 3.#数据缺失值填充及可视化 4.#这里以天为单位，把缺失数据填充上 这里填充的是线性取值 5.steps_df = steps_df.resample('D').interpolate('linear') 6.print(steps_df.runDistance［'20160427': '20230114'］) 图525缺失数据填充结果 时间序列ACF是时间序列分析中的一种重要工具，用于研究时间序列数据中的自相关性。自相关性是指在同一时间序列中，不同时刻的数据之间的相关性。ACF是一种描述时间序列数据在不同时间延迟下的相关性的方法。ACF可以通过计算时间序列数据与其自身在不同时间延迟下的相关性系数来计算。具体来说，ACF是时间序列数据与其自身在不同时间间隔内的相关系数的函数。在计算ACF时，一个时间序列数据集被拆分成不同的时间段，并计算在不同时间延迟下的相关性系数。 PACF是一种描述时间序列的自相关性的统计工具。它用来衡量在给定两个时间点之间的距离上，一个时间序列在去除其前面的时间点对它的影响后,对后面的时间点的影响。故PACF可以帮助确定一个时间序列需要多少个滞后值才能很好地对其进行预测。PACF通常用于进行时间序列建模、诊断和选择自回归模型阶数。 画出ACF、PACF图像，代码如下，结果如图526所示。 1.#画出ACF、PACF图像 2.def plotds(xt, nlag = 30, fig_size = (12, 10)): 3.if not isinstance(xt, pd.Series): 4.xt = pd.Series(xt) 5.plt.figure(figsize = fig_size) 6.layout = (2, 2) 7. plt.rcParams.update({'font.size': 20}) 8.ax_xt = plt.subplot2grid(layout, (0, 0), colspan = 2) 9.ax_acf = plt.subplot2grid(layout, (1, 0)) 10.ax_pacf = plt.subplot2grid(layout, (1, 1)) 11.xt.plot(ax = ax_xt) 12.ax_xt.set_title('Time Series') 13.plot_acf(xt, lags = nlag, ax = ax_acf) 14.plot_pacf(xt, lags = nlag, ax = ax_pacf) 15.plt.tight_layout() 16.return None 17.#画出ACF、PACF图像 18.plotds(steps_df［'runDistance'］.dropna(), nlag = 50) 图526ACF、PACF图像 进行时间序列分析前，必须判断其是否平稳，需要使用ADF方法进行平稳性检验，代码如下： 1.#平稳性检验 2.diff = 0 3.adf = ADF(steps_df［'runDistance'］) 4.if adf［1］ > 0.05: 5.print(u'原始序列经检验不平稳，p值为:%s'%(adf［1］)) 6.else: 7.print(u'原始序列经检验平稳，p值为:%s'%(adf［1］)) 实验结果发现，原始序列经检验不平稳，p值为0．8338039027785843。 如果序列值彼此之间没有任何相关性，那就意味着该序列是一个没有记忆的序列，过去的行为对将来的发展没有丝毫影响，这种序列称之为纯随机序列。从统计分析的角度而言，纯随机序列是没有任何分析价值的序列，也称白噪声检验。白噪声序列检验代码如下： 1.from statsmodels.stats.diagnostic import acorr_ljungbox 2.lb=acorr_ljungbox(steps_df［'runDistance'］,lags=1) #返回的是DataFrame 不能用嵌套列表 3.p=lb.values［0,1］ #获取第0行第1列数据 4.if p<0.05: 5.print (u'原始序列为非白噪声序列，p值为:%s'%p) 6.else: 7.print (u'原始序列为白噪声序列，p值为:%s'%p) 实验结果发现，原始序列为非白噪声序列，p值为3．084362836456756e193。 接下来对不平稳的数据进行平稳化处理，代码如下，平稳化后的数据如图527所示。 1.# 3. 处理数据，平稳化数据 2.# 这里只是简单地作了一阶差分，还有其他平稳化时间序列的方法 3.# 可以查询资料后改进这里的平稳化效果 4.steps_diff = steps_df.diff(1) 5.steps_diff = steps_diff.dropna() 6.print(steps_diff.head()) 7.print(steps_diff.dtypes) 8.plotds(steps_diff［'runDistance'］.dropna(),nlag = 50) 图527平稳化后数据显示 对平稳化后的数据进行平稳性检验。代码如下： 1.#平稳性检验 2.diff = 0 3.adf = ADF(steps_diff［'runDistance'］) 4.if adf［1］ > 0.05: 5.print(u'一阶差分序列经检验不平稳，p值为:%s'%(adf［1］)) 6.else: 7.print(u'一阶差分序列经检验平稳，p值为:%s'%(adf［1］)) 实验结果发现，一阶差分序列经检验平稳，p值为0．0。 白噪声检验，代码如下： 1.from statsmodels.stats.diagnostic import acorr_ljungbox 2.lb=acorr_ljungbox(steps_diff［'runDistance'］,lags=1) #返回的是DataFrame 不能用嵌套列表 3.p=lb.values［0,1］ #获取第0行第1列数据 4.if p<0.05: 5.print (u'一阶差分序列为非白噪声序列，p值为:%s'%p) 6.else: 7.print (u'一阶差分序列为白噪声序列，p值为:%s'%p) 实验结果发现，一阶差分序列为非白噪声序列，p值为7．93144056649956e95。 根据ACF和PACF定阶并建立模型，代码如下，结果如图528所示。 1.# 4. 根据ACF和PACF定阶并建立模型 2.model = ARIMA(steps_df［'runDistance'］, order = (2, 1, 2)) 3.model_fit = model.fit() 4.print(model_fit.summary()) 图528模型拟合结果显示 模型拟合代码如下。结果如图529所示。 1.#模型拟合 2.steps_df［'ARIMA'］ = model_fit.predict(typ='levels') 3.f, axarr = plt.subplots(1, sharex = True) 4.f.set_size_inches(12, 8) 5.steps_df［'runDistance'］.plot(color = 'b', linestyle = '-', ax = axarr) 6.steps_df［'ARIMA'］.plot(color = 'r', linestyle = '--', ax = axarr) 7.axarr.set_title('ARIMA(2, 1, 2)') 8.plt.rcParams.update({'font.size': 20}) 9.plt.xlabel('Index') 10.plt.ylabel('runDistance') 11.plt.show() 图529模型拟合结果可视化 模型预测并可视化预测结果，代码如下，预测结果可视化如图530所示。 1.#预测 2.output = model_fit.predict('20180201','20180207',dynamic=True,typ='levels') 3.#使用模型预测数据 4.#print(output) 5.# 6.可视化预测结果 6.steps_forcast = pd.concat(［steps_df.runDistance［'20180115':'20180207'］,output］,axis=1, keys=［'original','predicted'］) 7.plt.figure() 8.plt.plot(steps_forcast) 9.plt.title('Original vs predicted') 10.plt.savefig('./steps_pred.png',format='png') 11.plt.show() 图530预测可视化结果 模型评估代码如下： 1.#模型评估，平均绝对误差MAE、均方误差MSE、均方根误差RMSE 2.#对短期预测结果进行评估 3.short_label = steps_df.runDistance［'20200201': '20200202'］ 4.short_prediction = output［:2］ 5.short_mse_score = mse(short_label,short_prediction) 6.short_rmse_score = math.sqrt (mse(short_label,short_prediction)) 7.short_mae_score = mae(short_label,short_prediction) 8.print('short MSE:%.4f,short_RMSE:%.4f,short_MAE:%.4f'%(short_mse_score,short_rmse_score,short_mae_score)) 短期预测评估结果为： short MSE： 133442．5341,short RMSE： 365．2979,short MAE： 353．5008。 1.#对长期预测结果进行评估 2.all_label= steps_df.runDistance［'20200201': '20200207'］ 3.all_prediction = output 4.long_mse_score = mse(all_label,all_prediction) 5.long_rmse_score = math.sqrt(mse(all_label, all_prediction)) 6.long_mae_score = mae(all_label, all_prediction) 7.print('long_MSE: %.4f,long_RMSE: %.4f,long_MAE: %.4f'% (long_mse_score, long_rmse_score, long_mae_score)) 长期预测评估结果为： long_MSE： 94948．9715,long_RMSE： 308．1379,long_MAE： 250．0324。 由短期预测结果和长期预测结果的对比显示，长期预测结果更好。 对后续数据进行预测，代码如下，预测结果如图531所示。 1.#对后续数据进行预测 2.from statsmodels.graphics.tsaplots import plot_predict 3.from statsmodels.tsa.arima.model import ARIMA 4.dta = steps_df.runDistance［'2020/12/15': '2020/12/30'］ #选择可视化的原始数据区间 5.fig, ax = plt.subplots() 6.ax = dta.loc［'2020/12/15':］.plot(ax=ax) #设置坐标轴起点 7.plot_predict(model.fit(),'2020/12/25','2021/01/30',ax=ax) #可视化预测时间起点与终点 8.plt.show() 图531后续数据预测结果 5．3．2案例： LSTM模型分析数据 1． LSTM模型原理 在深度学习领域中，尤其是循环神经网络(recurrent neural network, RNN)，“长期依赖”问题是普遍存在的。长期依赖产生的原因是当神经网络的节点经过许多阶段的计算后，之前比较长的时间片的特征已经被覆盖。长短期记忆(long shortterm memory, LSTM)网络是RNN的一种变体,可以很有效地解决简单RNN的梯度爆炸或消失问题。而LSTM之所以能够解决RNN的长期依赖问题，是因为LSTM引入了门(gate)机制用于控制特征的流通和损失。LSTM是由一系列LSTM单元(LSTM unit)组成，其链式结构如图532所示。 图532LSTM链式结构 LSTM区别于RNN的地方，主要就在于它在算法中加入了一个判断信息有用与否的“处理器”，这个处理器作用的结构被称为cell。 一个cell当中放置了三扇门，分别叫作输入门、遗忘门和输出门。一个信息进入LSTM的网络当中，可以根据规则来判断是否有用。只有符合算法认证的信息才会留下，不符合的信息则通过遗忘门被遗忘。具体来讲，三个门的基本功能如下所述： (1) 遗忘门的功能是决定应丢弃或保留哪些信息。来自前一个隐藏状态的信息和当前输入的信息同时传递到sigmoid函数中，输出值介于0～1，越接近0意味着越应该丢弃，越接近1意味着越应该保留； (2) 输入门用于更新cell状态。首先将前一层隐藏状态的信息和当前输入的信息传递到sigmoid函数中。将值调整到0～1来决定要更新哪些信息。0表示不重要，1表示重要。其次还要将前一层隐藏状态的信息和当前输入的信息传递到tanh函数中，创造一个新的候选值向量。最后将sigmoid函数的输出值与tanh函数的输出值相乘，sigmoid函数的输出值将决定tanh函数的输出值中哪些信息是重要且需要保留下来的； (3) 输出门用来确定下一个隐藏状态的值，隐藏状态包含了先前输入的信息。首先，将前一个隐藏状态和当前输入传递到sigmoid函数中，然后将新得到的cell状态传递给tanh函数。最后将tanh函数的输出与sigmoid函数的输出相乘，以确定隐藏状态应携带的信息。再将隐藏状态作为当前cell的输出，把新的cell状态和新的隐藏状态传递到下一个时间步长中。 2． 分析实验过程 LSTM模型预测的基本程序包括构建网络模型、对模型进行训练、利用训练好的模型进行预测、对预测结果进行评估。利用LSTM处理数据的流程如下。 导入相应的包，代码如下： 1.import numpy as np 2.import pandas as pd 3.import torch.nn as nn 4.import torch 5.import matplotlib.pyplot as plt 6.import matplotlib.ticker as mticker 7.import statsmodels.api as sm 8.import statsmodels.tsa.api as tsa 9.import math 10.import torch.utils.data as Data 绘制序列图像设置,代码如下： 1.#绘制序列 2.def plot_series(time,series,format="-",start=0,end=None,label=None): 3.#根据时间轴和对应数据列表绘制序列图像 4.plt.plot(time［start:end］, series［start:end］,format,label=label) 5.#设置横纵轴意义 6.plt.xlabel("Time") 7.plt.ylabel("Value") 8.#设置图例说明字体大小 9.if label: 10.plt.legend(fontsize=14) 11.plt.rcParams.update({'font.size': 20}) 12.#显示网格 13.plt.grid(True) 读取数据，代码如下： 1.data=pd.read_csv('Steps.csv',index_col=0,na_values='+9999,9')#读取文件，将日期设为索引 2.data=data［'runDistance'］#选取runDistance一列 3. 4.data.index=pd.to_datetime(data.index)#将data.index设置为时间格式 5.start_time=pd.to_datetime('2019-01-01 00:00:00') 6.end_time=pd.to_datetime('2019-06-30 23:00:00') 7.data=data［start_time:end_time］ 8.data=data.dropna()#剔除NaN的数据 9.# data=data.str.split(",",expand=True)［0］ 10.# data=data.astype("int")/10#将TMP数据从str转换为int，并获取正确数值 11. 12.index=pd.date_range(start=start_time,end=end_time,freq="H") 13.data=data.reindex(index)#将时间补全(前面有丢弃操作)，并将间隔时间设置为1h，重新设置data的索引 14.#进行插值(部分补全的时间没有对应的数据) 15.data=data.interpolate() 16.#将数据转换为array类型， 17.series=np.array(data) 数据可视化，代码如下，可视化结果如图533所示。 1.#数据可视化 2.fig,ax=plt.subplots(figsize=(20,6)) 3.#设置纵轴单位 4.ax.yaxis.set_major_formatter(mticker.FormatStrFormatter('%d ℃')) 5.data.plot() 6.plt.xlabel('Date') 7.plt.ylabel('runDistance') 8.plt.grid(True) 9.plt.show() 图533数据可视化结果显示 设置超参数，代码如下： 1.#设置超参数 2.input_size=1 3.hidden_size=128 4.output_size=1 5.epochs=100 6.lr=0.05 7.batch_size=20 8.time_step=12 划分训练集和测试集，代码如下： 1.#前140天的数据作为训练集 2.train_data=data［0:140 * 24］ 3.#剩下的时间数据作为测试集 4.test_data=data［140 * 24:］ 5.#数据归一化 6.train_data_normalized=(train_data-train_data.min())/(train_data.max()-train_data.min()) 7.test_data_normalized=(test_data-train_data.min())/(train_data.max()-train_data.min()) 滑动窗口采样，代码如下： 1.train_x = ［］ 2.train_y = ［］ 3.test_x = ［］ 4.test_y = ［］ 5.#对训练数据采样 6.i = 0 7.while(i + time_step+output_size