0

0

Pandas 多列时间序列按 MMSI 与航次分组的等间隔重采样与插值教程

心靈之曲

心靈之曲

发布时间:2026-01-18 10:08:17

|

640人浏览过

|

来源于php中文网

原创

Pandas 多列时间序列按 MMSI 与航次分组的等间隔重采样与插值教程

本文详解如何对含 mmsi 和 departures_count 分组标识的船舶轨迹数据,按 10 分钟固定频率进行重采样,并对 calc_speed、coursechange 等多列执行线性/立方插值,避免 groupby + resample 直接调用导致的 nan 或重复值问题。

在船舶 AIS 数据分析中,原始记录常存在不规则采样间隔(如数秒至数十分钟不等),而下游建模或可视化往往要求统一时间粒度(如每 10 分钟一个观测点)。直接使用 groupby(...).resample('10Min').interpolate() 容易失败——因为 resample 在分组内默认以原始索引为基准聚合,若未对齐目标网格,会返回全 NaN 或错误复用首尾值。

正确做法是:为每个 (mmsi, departures_count) 子组独立构建 10 分钟规则时间网格,再通过 reindex → interpolate → reindex 三步完成精准插值。该方案兼顾上采样(填补密集点间的空隙)与下采样(跨大间隔插值),且天然支持多列同步处理。

以下为完整实现代码(支持线性与立方插值):

import pandas as pd
import numpy as np

def resample_trip(g, freq='10Min', method='linear'):
    """
    对单个航次子组执行等间隔重采样插值
    :param g: 分组后的 DataFrame(已设 timestamp 为 DatetimeIndex)
    :param freq: 目标频率,如 '10Min'
    :param method: 插值方法,'linear' / 'cubic' / 'time' 等
    :return: 重采样后 DataFrame,索引为规则时间点
    """
    if len(g) == 0:
        return g

    # 步骤1:生成覆盖全程的规则时间网格(向上/向下取整到 freq 边界)
    start = g.index[0].floor(freq)
    end = g.index[-1].ceil(freq)
    rng = pd.date_range(start, end, freq=freq)

    # 步骤2:扩展索引并插值(limit_direction='both' 确保两端可插)
    g_extended = g.reindex(g.index.union(rng))
    g_interp = g_extended.interpolate(method=method, limit_direction='both')

    # 步骤3:精确提取目标网格点(丢弃原始非网格点)
    result = g_interp.reindex(rng)
    return result

# 预处理:确保 timestamp 为 datetime 并设为索引
df["timestamp"] = pd.to_datetime(df["timestamp"])
df = df.set_index("timestamp")

# 按 MMSI 与航次分组,应用自定义重采样函数
out = df.groupby(["mmsi", "departures_count"], group_keys=False).apply(
    resample_trip, freq='10Min', method='cubic'  # ← 切换 cubic 即可启用三次样条插值
)

print(out.head(10))

关键优势说明

阿里云AI平台
阿里云AI平台

阿里云AI平台

下载
  • 分组隔离性:每个 (mmsi, departures_count) 独立生成时间网格,避免跨航次污染;
  • 插值鲁棒性:reindex(...union...) 确保原始点全部保留,interpolate(limit_direction='both') 允许双向延伸插值(尤其对起止点有效);
  • 方法灵活:仅需修改 method 参数即可切换 'linear'(默认)、'cubic'(需至少 4 个点)、'time'(按实际时间距离加权)等;
  • 多列安全:所有数值列(如 calc_speed, coursechange, lat, lon)自动同步插值,无需逐列指定。

⚠️ 注意事项

  • 若某航次数据点少于 2 个,cubic 插值将退化为线性或报错,建议增加判断逻辑(如 if len(g) < 4: method = 'linear');
  • coursechange(航向变化)存在周期性(0°/360°跳变),线性插值可能产生不合理中间值,此时应先做相位解缠(np.unwrap)再插值;
  • 对超大数据集(228 万+ 行),可添加 progress_apply 或分块处理提升响应速度。

通过该方法,您将获得严格对齐的 10 分钟粒度轨迹数据,为后续速度趋势分析、航向模式挖掘或深度学习建模奠定高质量时序基础。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
Python 时间序列分析与预测
Python 时间序列分析与预测

本专题专注讲解 Python 在时间序列数据处理与预测建模中的实战技巧,涵盖时间索引处理、周期性与趋势分解、平稳性检测、ARIMA/SARIMA 模型构建、预测误差评估,以及基于实际业务场景的时间序列项目实操,帮助学习者掌握从数据预处理到模型预测的完整时序分析能力。

80

2025.12.04

Python 数据清洗与预处理实战
Python 数据清洗与预处理实战

本专题系统讲解 Python 在数据清洗与预处理中的核心技术,包括使用 Pandas 进行缺失值处理、异常值检测、数据格式化、特征工程与数据转换,结合 NumPy 高效处理大规模数据。通过实战案例,帮助学习者掌握 如何处理混乱、不完整数据,为后续数据分析与机器学习模型训练打下坚实基础。

33

2026.01.31

if什么意思
if什么意思

if的意思是“如果”的条件。它是一个用于引导条件语句的关键词,用于根据特定条件的真假情况来执行不同的代码块。本专题提供if什么意思的相关文章,供大家免费阅读。

847

2023.08.22

c语言union的用法
c语言union的用法

c语言union的用法是一种特殊的数据类型,它允许在相同的内存位置存储不同的数据类型,union的使用可以帮助我们节省内存空间,并且可以方便地在不同的数据类型之间进行转换。使用union时需要注意对应的成员是有效的,并且只能同时访问一个成员。本专题为大家提供union相关的文章、下载、课程内容,供大家免费下载体验。

129

2023.09.27

c语言union的用法
c语言union的用法

c语言union的用法是一种特殊的数据类型,它允许在相同的内存位置存储不同的数据类型,union的使用可以帮助我们节省内存空间,并且可以方便地在不同的数据类型之间进行转换。使用union时需要注意对应的成员是有效的,并且只能同时访问一个成员。本专题为大家提供union相关的文章、下载、课程内容,供大家免费下载体验。

129

2023.09.27

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

25

2026.03.13

Python异步编程与Asyncio高并发应用实践
Python异步编程与Asyncio高并发应用实践

本专题围绕 Python 异步编程模型展开,深入讲解 Asyncio 框架的核心原理与应用实践。内容包括事件循环机制、协程任务调度、异步 IO 处理以及并发任务管理策略。通过构建高并发网络请求与异步数据处理案例,帮助开发者掌握 Python 在高并发场景中的高效开发方法,并提升系统资源利用率与整体运行性能。

44

2026.03.12

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

174

2026.03.11

Go高并发任务调度与Goroutine池化实践
Go高并发任务调度与Goroutine池化实践

本专题围绕 Go 语言在高并发任务处理场景中的实践展开,系统讲解 Goroutine 调度模型、Channel 通信机制以及并发控制策略。内容包括任务队列设计、Goroutine 池化管理、资源限制控制以及并发任务的性能优化方法。通过实际案例演示,帮助开发者构建稳定高效的 Go 并发任务处理系统,提高系统在高负载环境下的处理能力与稳定性。

50

2026.03.10

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
大数据(MySQL)视频教程完整版
大数据(MySQL)视频教程完整版

共200课时 | 19.3万人学习

PHP会话控制/文件上传/分页技术
PHP会话控制/文件上传/分页技术

共22课时 | 2.2万人学习

马哥初级运维视频教程
马哥初级运维视频教程

共80课时 | 20.9万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号