使用 Python 和 AWS 构建实时天气数据收集系统-Python教程-PHP中文网

使用 Python 和 AWS 构建实时天气数据收集系统

花韻仙語

发布： 2025-01-13 08:05:53

原创

1277人浏览过

在数据驱动的决策时代，天气数据已成为企业和个人不可或缺的资源。无论是物流、农业还是旅游规划，实时天气数据采集系统都能提供宝贵的参考依据。本文将逐步指导您如何利用python、openweather api和aws s3构建一个高效的天气数据采集系统。

项目概述

本项目将演示如何：

使用OpenWeather API获取天气数据。
在运行Python脚本时实时显示天气信息。
将数据存储到AWS S3存储桶中，以便进行历史数据追踪和分析。

完成本教程后，您将拥有一个完整的系统，它展现了DevOps原则的关键方面，包括自动化、云集成和可扩展性。

AWS服务简介

Amazon S3（简单存储服务）

功能：Amazon S3是一种高度可扩展、安全的云端对象存储服务。在本项目中，它用于存储历史天气数据，以便后续分析。

立即学习“Python免费学习笔记（深入）”；

主要特性：

可扩展性：轻松应对不断增长的数据集。
持久性：确保数据在多重冗余机制下不会丢失。
集成性：与Lambda、Glue和Athena等其他AWS服务无缝集成。

在我们的系统中，S3存储桶充当OpenWeather API获取所有天气数据的存储库。

逐步实施

步骤1：准备工作

在开始编写代码之前，请确保您已准备好以下条件：

AWS账户：创建一个用于存储天气数据的AWS S3存储桶。
OpenWeather API密钥：注册OpenWeather并获取您的API密钥。
已安装Python：确保您的系统已安装Python 3.x。本项目将使用VS Code作为集成开发环境（IDE）。

安装依赖项：创建一个名为requirements.txt的文件，内容如下：

boto3==1.26.137
python-dotenv==1.0.0
requests==2.28.2

登录后复制

运行以下命令安装依赖项：

pip install -r requirements.txt

使用 Python 和 AWS 构建实时天气数据收集系统

步骤2：环境配置

创建项目目录：

mkdir weather-data-collector
cd weather-data-collector

登录后复制

创建.env文件：

将API密钥等敏感信息安全地存储在.env文件中：

openweather_api_key=your_openweather_api_key
aws_access_key_id=your_aws_access_key_id
aws_secret_access_key=your_aws_secret_access_key
s3_bucket_name=your_s3_bucket_name

登录后复制

步骤3：获取天气数据

创建一个Python脚本，使用OpenWeather API获取天气数据，并利用boto3库将数据上传到S3存储桶。

使用 Python 和 AWS 构建实时天气数据收集系统

fetch_weather.py:

import os
import json
import boto3
import requests
from datetime import datetime
from dotenv import load_dotenv

# 加载环境变量
load_dotenv()

class WeatherDashboard:
    def __init__(self):
        self.api_key = os.getenv('OPENWEATHER_API_KEY')
        self.bucket_name = os.getenv('S3_BUCKET_NAME')  # 修正变量名
        self.s3_client = boto3.client('s3')

    def create_bucket_if_not_exists(self):
        # ... (代码与原文相同) ...

    def fetch_weather(self, city):
        # ... (代码与原文相同) ...

    def save_to_s3(self, weather_data, city):
        # ... (代码与原文相同) ...

def main():
    dashboard = WeatherDashboard()
    # ... (代码与原文相同) ...

if __name__ == "__main__":
    main()

登录后复制

步骤4：运行系统

执行以下命令获取和显示天气数据，并将数据上传到S3：

python fetch_weather.py

使用 Python 和 AWS 构建实时天气数据收集系统