利用Pandas创建条件列:识别用户新增零售商

利用pandas创建条件列:识别用户新增零售商

本文介绍如何在Pandas中,针对用户在不同时间段的零售商使用数据,识别并标记出在后期出现的新增零售商。通过两种高效方法——利用merge函数的indicator参数和MultiIndex.isin方法——详细演示如何创建条件列,从而实现按用户分组的集合差异分析,为数据洞察提供支持。

问题背景与目标

在用户行为分析中,我们经常需要比较不同时间段内用户行为的变化。一个常见的场景是,给定用户在前期(pre-period)和后期(post-period)访问的零售商列表,我们需要识别出在后期才首次出现的新增零售商。这里的关键在于,新增零售商的判断是基于每个用户独立进行的,即对于特定用户而言,某个零售商在后期出现但前期未曾出现,则被视为该用户的新增零售商。

例如,我们有以下两组数据,分别代表用户在前期和后期访问的零售商记录:

import pandas as pd# 前期数据 (sample1)sample1 = pd.DataFrame(    {        'user_id': [45, 556, 556, 556, 556, 556, 556, 1344, 1588, 2063, 2063, 2063, 2673, 2982, 2982],        'retailer': ['retailer_1', 'retailer_1', 'retailer_2', 'retailer_3', 'retailer_4', 'retailer_5', 'retailer_6',                      'retailer_3', 'retailer_2', 'retailer_2', 'retailer_3', 'retailer_7', 'retailer_1', 'retailer_1', 'retailer_2']    })# 后期数据 (sample2)sample2 = pd.DataFrame(    {        'user_id': [45, 45, 556, 556, 556, 556, 556, 556, 1344, 1588, 2063, 2063, 2063, 2673, 2673, 2982, 2982],        'retailer': ['retailer_1', 'retailer_6', 'retailer_1', 'retailer_2', 'retailer_3', 'retailer_4', 'retailer_5', 'retailer_6',                      'retailer_3', 'retailer_2', 'retailer_2', 'retailer_3', 'retailer_7', 'retailer_1', 'retailer_2', 'retailer_1', 'retailer_2']    })print("前期数据 (sample1):")print(sample1)print("n后期数据 (sample2):")print(sample2)

我们的目标是在后期数据 sample2 中添加一个名为 is_new_retailer 的条件列,如果该行的 (user_id, retailer) 组合在 sample1 中不存在,则标记为1(表示新增),否则标记为0(表示非新增)。

期望的输出结果示例如下:

    user_id    retailer  is_new_retailer0        45  retailer_1                01        45  retailer_6                1  # user 45, retailer_6 在 sample1 中不存在...14     2673  retailer_2                1  # user 2673, retailer_2 在 sample1 中不存在...

方法一:利用 merge 函数的 indicator 参数

Pandas的 merge 函数提供了一个 indicator 参数,可以在合并结果中添加一列,指示每行数据是来自左表、右表还是两者兼有。这对于识别集合差异非常有用。

实现步骤

对 sample2 和 sample1 进行左连接(how=’left’),连接键为 [‘user_id’, ‘retailer’]。设置 indicator=’is_new_retailer’,这将生成一个名为 is_new_retailer 的新列,其值包括 left_only(仅在左表)、right_only(仅在右表)和 both(左右表均有)。筛选 is_new_retailer 列中值为 left_only 的行,这表示这些 (user_id, retailer) 组合仅存在于 sample2 中,而不存在于 sample1 中。将布尔值转换为整数(1表示新增,0表示非新增)。

示例代码

# 方法一:使用 merge 和 indicator 参数def find_new_retailers_with_merge(df_post, df_pre):    """    使用 Pandas merge 函数的 indicator 参数识别新增零售商。    Args:        df_post (pd.DataFrame): 后期数据,包含 user_id 和 retailer。        df_pre (pd.DataFrame): 前期数据,包含 user_id 和 retailer。    Returns:        pd.DataFrame: 包含 'is_new_retailer' 列的后期数据。    """    # 执行左连接,并使用 indicator 参数    # 连接键是 ['user_id', 'retailer'],确保是按用户-零售商组合进行匹配    merged_df = df_post.merge(df_pre, on=['user_id', 'retailer'], how='left', indicator='_merge_indicator')    # 根据 indicator 列判断是否为新增零售商    # 'left_only' 表示该组合只存在于 df_post 中,而不在 df_pre 中    merged_df['is_new_retailer'] = (merged_df['_merge_indicator'] == 'left_only').astype(int)    # 移除临时的 indicator 列    merged_df = merged_df.drop(columns=['_merge_indicator'])    return merged_dfresult_merge = find_new_retailers_with_merge(sample2, sample1)print("n方法一结果 (使用 merge indicator):")print(result_merge)

注意事项

此方法简洁高效,尤其适用于需要合并数据并同时识别差异的场景。merge 操作会根据连接键的组合进行匹配。如果 sample1 和 sample2 中 (user_id, retailer) 组合存在重复,此方法依然能正确识别新增组合,但如果 df_post 中原始行存在重复,结果中也会保留这些重复。

方法二:利用 MultiIndex.isin 进行多列集合判断

当需要对多列组合进行精确的集合成员判断时,创建 MultiIndex 并使用其 isin 方法是一个非常强大且通用的解决方案。

实现步骤

从 sample2 和 sample1 中分别创建包含 user_id 和 retailer 两列的 MultiIndex。使用 sample2 的 MultiIndex 调用 isin 方法,传入 sample1 的 MultiIndex 作为参数。这将返回一个布尔序列,指示 sample2 中的每个 (user_id, retailer) 组合是否在 sample1 中存在。对布尔序列进行逻辑非(~)操作,因为我们寻找的是 不在 sample1 中的组合。将布尔值转换为整数。

示例代码

# 方法二:使用 MultiIndex.isindef find_new_retailers_with_multiindex(df_post, df_pre):    """    使用 Pandas MultiIndex.isin 方法识别新增零售商。    Args:        df_post (pd.DataFrame): 后期数据,包含 user_id 和 retailer。        df_pre (pd.DataFrame): 前期数据,包含 user_id 和 retailer。    Returns:        pd.DataFrame: 包含 'is_new_retailer' 列的后期数据。    """    # 从 df_post 和 df_pre 创建 MultiIndex    # 这将把 'user_id' 和 'retailer' 组合成一个复合键    multi_index_post = pd.MultiIndex.from_frame(df_post[['user_id', 'retailer']])    multi_index_pre = pd.MultiIndex.from_frame(df_pre[['user_id', 'retailer']])    # 检查 df_post 中的每个复合键是否在 df_pre 中    # (~...) 表示如果不在 df_pre 中,则为 True (即新增)    df_post['is_new_retailer'] = (~multi_index_post.isin(multi_index_pre)).astype(int)    return df_postresult_multiindex = find_new_retailers_with_multiindex(sample2.copy(), sample1) # 使用 .copy() 避免修改原始 sample2print("n方法二结果 (使用 MultiIndex.isin):")print(result_multiindex)

注意事项

MultiIndex.isin 方法在处理多列组合的集合成员判断时非常直观和高效。此方法直接在原始 DataFrame 上添加列,因此如果需要保留原始 DataFrame,请先进行复制(如示例中的 sample2.copy())。它不涉及合并操作,因此对于只需要进行集合判断而不需要合并其他列的场景,可能比 merge 更简洁。

总结与比较

两种方法都能有效地识别用户新增零售商,并在后期数据中创建相应的条件列。

merge 与 indicator 参数

优点:代码简洁,易于理解,特别适合需要将两个数据集合并并同时标记差异的场景。缺点:会生成一个中间的 _merge_indicator 列,需要后续删除。如果只需要判断集合成员关系而不需要合并其他列,可能会显得稍微冗余。

MultiIndex.isin 方法

优点:更直接地表达了多列组合的集合成员判断逻辑,适用于纯粹的集合操作。性能通常也很好。缺点:需要创建 MultiIndex 对象,对于不熟悉 MultiIndex 的用户来说可能稍显复杂。

在实际应用中,选择哪种方法取决于具体的需求和个人偏好。如果你的任务是基于一个主表(后期数据)去检查其记录在另一个表(前期数据)中的存在性,并且主要关注的是“新增”标记,那么 MultiIndex.isin 提供了一种非常直接且高效的解决方案。如果你的分析还涉及从前期数据中引入其他列,或者你更习惯SQL风格的连接操作,那么 merge 配合 indicator 也是一个非常好的选择。两种方法都体现了Pandas在处理复杂数据关系方面的灵活性和强大功能。

以上就是利用Pandas创建条件列:识别用户新增零售商的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1373466.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月14日 13:16:50
下一篇 2025年12月14日 13:17:04

相关推荐

  • Python多目录项目导入模块深度解析与最佳实践

    本文旨在深入探讨python多目录项目中常见的模块导入问题及其解决方案。我们将分析python的导入机制,区分独立包与子包结构下的导入策略,并提供正确的执行方式。文章还将强调将可执行脚本与可复用包分离的最佳实践,帮助开发者构建结构清晰、易于维护的python项目。 在Python项目开发中,随着项目…

    好文分享 2025年12月14日
    000
  • Odoo产品变体视图中基于产品模板字段实现搜索功能指南

    本教程详细介绍了如何在odoo的产品变体(product.product)列表中添加一个基于产品模板(product.template)自定义字段的搜索功能。文章将指导您完成自定义字段的定义、关联字段的创建,并重点阐述在搜索视图中使用filter_domain而非domain的关键区别与正确实践,以…

    2025年12月14日
    000
  • 解决Django应用在Docker中URL不匹配问题:容器更新与代码同步

    当django应用在本地正常运行,但在docker部署中出现特定url 404错误时,其根本原因往往是docker容器或镜像未能同步最新的代码变更。这导致容器内部运行的是旧版本的应用代码,从而无法识别新增的url模式。解决此问题需要确保docker环境被正确更新,通过重建镜像和容器来加载最新的代码配…

    2025年12月14日
    000
  • 使用Python和Selenium抓取动态网页数据:处理Toggle按钮

    本文详细介绍了如何使用Python结合Selenium和BeautifulSoup库来抓取包含动态内容的网页数据。针对需要用户交互(如点击Toggle按钮)才能显示的数据,教程阐述了Selenium如何模拟浏览器行为,定位并点击动态元素,获取更新后的页面HTML,再利用BeautifulSoup进行…

    2025年12月14日
    000
  • Python Asyncio中实现异步惰性加载属性的正确姿势

    本文探讨了在Python Asyncio环境中实现异步惰性加载属性的挑战与解决方案。针对在描述符的`__get__`方法中直接`await`异步操作的常见误区,文章指出正确的做法是让属性本身返回一个可等待对象,并将`await`操作移至属性的调用方,从而避免了`RuntimeError`和`Runt…

    2025年12月14日
    000
  • Python datetime模块:构建健壮计时器并避免精确时间比较陷阱

    本文探讨了在python中使用datetime模块构建计时器时,直接比较datetime.now() == endtime可能导致的问题。由于datetime对象的微秒级精度以及代码执行时序的不确定性,这种精确匹配往往会失败,导致程序无法按预期终止。本教程将深入解释其原因,并提供使用datetime…

    2025年12月14日
    000
  • Python网页版如何防止SQL注入_Python网页版SQL注入防护与安全编码方法

    防止SQL注入的核心是避免拼接SQL,应使用参数化查询或ORM框架,辅以输入验证和最小权限原则。例如,SQLite和MySQL支持占位符传递用户数据,SQLAlchemy等ORM自动防注入;同时需校验输入格式、长度,限制数据库账户权限,并隐藏敏感错误信息,确保安全编码。 防止SQL注入是Python…

    2025年12月14日
    000
  • Python END_FINALLY 字节码的解析与行为分析(旧版本)

    本文深入探讨了python虚拟机中`end_finally`字节码的作用及其在旧版本python(如2.7)`try-except`结构中的行为。`end_finally`主要用于在`finally`块结束时,或当没有`finally`块且没有`except`块匹配时,恢复异常传播、`return`…

    2025年12月14日
    000
  • 如何在Flet-FastAPI应用中实现文件下载功能

    本文详细介绍了在Flet与FastAPI集成应用中实现文件下载功能的正确方法。通过将Flet的UI事件与FastAPI的文件响应端点解耦,利用`page.launch_url_async`触发浏览器下载,并结合FastAPI的`FileResponse`及`Content-Disposition`头…

    2025年12月14日
    000
  • PyTorch参数更新不明显?深度解析学习率与梯度尺度的影响

    在使用PyTorch进行模型训练时,开发者有时会遇到参数看似没有更新的问题,即使已正确调用优化器。本文将深入探讨这一常见现象,揭示其背后往往是学习率设置过低,导致参数更新幅度相对于参数自身值或梯度而言微不足道。我们将通过代码示例和详细分析,演示如何诊断并解决此类问题,强调学习率在优化过程中的关键作用…

    2025年12月14日
    000
  • 高效查找布尔数组中下一个真值索引的优化策略

    本文探讨了在布尔数组中从给定位置高效查找下一个`true`值索引的策略。针对频繁查询场景,提出了一种基于预计算的优化方法。通过一次性反向遍历数组构建辅助索引表,后续每次查询可在o(1)时间复杂度内完成,显著优于传统的线性扫描方法,从而提升系统性能。 在处理布尔数组(或列表)时,一个常见的需求是从特定…

    2025年12月14日
    000
  • 使用Selenium自动化处理动态下拉菜单与数据提取教程

    本教程详细介绍了如何使用selenium webdriver处理网页中动态展开的下拉菜单,并从中提取嵌套的子分类链接。我们将通过识别并迭代点击展开图标,实现所有子菜单的可见化,随后筛选并收集目标href属性。内容涵盖selenium环境配置、元素定位技巧、动态dom交互策略,并提供完整的python…

    2025年12月14日
    000
  • 如何在Python描述符的__get__方法中处理异步调用

    本文探讨了在Python中实现异步延迟加载属性的挑战,特别是当数据获取需要异步操作时,如何在同步的`__get__`描述符方法中妥善处理。核心解决方案在于将属性本身设计为可等待对象,而非尝试在`__get__`内部同步阻塞或启动新的事件循环。通过将`@property`装饰器与异步方法结合,我们能确…

    2025年12月14日
    000
  • Flask应用url_quote导入错误解决方案:版本兼容性指南

    本文旨在解决flask应用中常见的`importerror: cannot import name ‘url_quote’ from ‘werkzeug.urls’`错误。该问题通常源于flask及其依赖库werkzeug之间的版本不兼容。教程将详细介…

    2025年12月14日
    000
  • PyTorch参数不更新:诊断与解决低学习率问题

    在pytorch模型训练中,参数不更新是一个常见问题,通常是由于学习率设置过低,导致每次迭代的参数更新幅度远小于参数自身的量级或梯度幅度。本文将深入分析这一现象,并通过示例代码演示,解释如何通过调整学习率来有效解决参数停滞不前的问题,并提供优化学习率的实践建议。 PyTorch参数不更新的常见原因与…

    2025年12月14日
    000
  • python如何使用send唤醒

    答案:通过send()方法可唤醒暂停的生成器并传递数据。首次用next()启动后,send(value)恢复yield执行并将值传入,实现双向通信,常用于协程式数据处理如累加器,是Python早期协程机制的核心。 在 Python 中,并没有直接叫 send 唤醒 的机制,但你可能是想问如何使用生成…

    2025年12月14日
    000
  • Python字节码深度解析:END_FINALLY在异常处理中的机制与行为

    本文深入探讨python字节码`end_finally`的核心作用,它主要负责在`finally`块执行结束后,或在没有匹配的`except`块时恢复异常传播,以及处理被`finally`暂停的控制流(如`return`/`continue`)。通过分析一个简单的`try-except`结构,我们将…

    2025年12月14日
    000
  • 使用NumPy通过矩阵幂运算高效计算斐波那契数列

    引言:斐波那契数列与矩阵方法 斐波那契数列是一个经典的数学序列,其中每个数字是前两个数字之和(F(0)=0, F(1)=1, F(n)=F(n-1)+F(n-2))。除了递归和迭代等传统方法,矩阵乘法提供了一种非常高效的计算斐波那契数列任意项的方法,尤其适用于计算较大的n值。 其核心思想是,斐波那契…

    2025年12月14日
    000
  • Python中正确格式化负数时间差的实用技巧

    本文探讨了在python中处理负数时间差的常见问题,特别是`time.strftime()`函数在遇到负秒数时无法正确显示负号。通过分析其内部机制,文章提出了一种自定义的解决方案,即在格式化前判断时间差的正负,对绝对值进行格式化,然后手动添加负号,从而确保时间差(包括负值)能够以`hh:mm:ss`…

    2025年12月14日
    000
  • PyTorch参数不更新:深入理解学习率与梯度尺度的影响

    在pytorch模型训练中,参数看似不更新是常见问题。本文将深入探讨这一现象的根本原因,即学习率、梯度大小与参数自身尺度的不匹配。我们将通过一个具体代码示例,分析为何微小的学习率结合相对较小的梯度会导致参数更新量微乎其微,从而在视觉上造成参数未更新的假象。文章将提供解决方案,并强调在优化过程中调试学…

    2025年12月14日
    000

发表回复

登录后才能评论
关注微信