MLRun 安全读取 CSV Artifact 方法
本文深入解析了在 MLRun 中安全、可靠读取远程存储(如 S3、V3IO)中 CSV Artifact 的最佳实践,重点强调摒弃易出错的原始方式(如直接调用 `pd.read_csv("s3://...")`),转而统一使用 `mlrun.get_dataitem(uri).as_df()` 这一高层抽象接口——它自动处理认证配置、协议适配、格式解析与跨后端兼容性,有效规避权限缺失、路径拼写错误、客户端未初始化等常见陷阱;同时详解 URI 构造规范、项目名严格匹配、调试技巧及 pipeline 中可维护的传参建议,为数据科学家和 MLOps 工程师提供开箱即用、健壮可扩展的 artifact 访问方案。

本文详解如何通过 MLRun 的 get_dataitem().as_df() 接口,正确加载存储在远程存储(如 S3)中的 CSV Artifact,避免因权限、路径拼写或认证缺失导致的读取失败。
本文详解如何通过 MLRun 的 get_dataitem().as_df() 接口,正确加载存储在远程存储(如 S3)中的 CSV Artifact,避免因权限、路径拼写或认证缺失导致的读取失败。
在 MLRun 中,将 DataFrame 以 TableArtifact 形式记录为 artifact(例如 context.log_artifact(TableArtifact('mydf', df=dataset, visible=True)))后,该文件会自动序列化为 CSV 并持久化至配置的远程存储(如 S3、V3IO 或 NFS)。但直接使用 pd.read_csv("s3://...") 通常会失败——原因包括:未配置 AWS 凭据、S3 客户端未初始化、路径中项目命名不匹配(如误用 test-pipeline 而非实际项目名 test_pipeline),或存储后端并非标准 S3 兼容接口(如 V3IO)。
✅ 正确做法是统一通过 MLRun 的数据抽象层访问,即使用 mlrun.get_dataitem() 获取可操作的数据项对象,再调用 .as_df() 方法自动完成格式解析与反序列化:
import mlrun # 替换为你的实际项目名(注意:需与创建项目时的 name 严格一致) project_name = "test-pipeline" # 构造 artifact 的完整 URI(格式固定:s3:///projects/ /artifacts/ / .csv) uri = f"s3://mlrun/projects/{project_name}/artifacts/data-prep-test-data-generator/0/mydf.csv" # 安全读取:MLRun 自动处理认证、协议适配与类型推断 df = mlrun.get_dataitem(uri).as_df() print(df.head())
⚠️ 关键注意事项:
- URI 拼写必须精确:projects/ 后是项目名(区分大小写和连字符)、artifacts/ 后是运行(run)的 uid 对应的目录名(可通过 run.status.artifact_uris 或 UI 查看),而非函数名;.csv 后缀不可省略。
- 项目名 ≠ 项目别名或环境变量名:务必确认项目真实名称(执行 mlrun.get_project("your-project").name 验证)。
- 无需手动配置 S3 客户端:get_dataitem 内部复用 MLRun 的全局存储配置(mlrun.set_environment(...) 或 MLRUN_DBPATH 等),确保与写入时环境一致。
- 支持多种格式透明转换:若 artifact 以 Parquet、JSON 等格式保存,.as_df() 同样适用,无需修改代码。
- 调试技巧:打印 mlrun.get_dataitem(uri).url 可验证解析后的实际地址;调用 .listdir() 可浏览目录结构。
? 进阶建议:为提升可维护性,推荐在 pipeline 中显式传递 artifact 的 key 和 uid,而非硬编码路径。例如,在下游函数中接收 context.get_input('mydf')(需上游设置 with_result=True),或通过 context.get_artifact('mydf') 获取元数据后构造 URI。
综上,mlrun.get_dataitem(uri).as_df() 是读取 MLRun artifact 的标准、安全且跨存储后端兼容的方式,应作为首选方案替代原始文件系统级访问。
终于介绍完啦!小伙伴们,这篇关于《MLRun 安全读取 CSV Artifact 方法》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布文章相关知识,快来关注吧!
拼多多订单自动取消怎么处理\_未支付超时解决方法
- 上一篇
- 拼多多订单自动取消怎么处理\_未支付超时解决方法
- 下一篇
- Golang读写锁实现与并发优化技巧
-
- 文章 · python教程 | 5小时前 |
- Python Jinja按模板后缀开启自动转义怎么配置
- 320浏览 收藏
-
- 文章 · python教程 | 5小时前 | Python 模板变量 Jinja StrictUndefined UndefinedError
- Python Jinja StrictUndefined怎样暴露缺失模板变量
- 477浏览 收藏
-
- 文章 · python教程 | 5小时前 | CLI · 命令行 · python · 命令行选项 list[str] Python Typer Typer重复参数 Typer列表参数 list[float]
- Python Typer可重复参数怎样收集为列表
- 157浏览 收藏
-
- 文章 · python教程 | 5小时前 | Python 后台任务 Worker Textual post_message
- Python Textual后台任务怎么把结果送回界面
- 317浏览 收藏
-
- 文章 · python教程 | 5小时前 | 查询优化 · Python explain 查询计划 Polars LazyFrame show_graph
- Python Polars LazyFrame怎样查看查询计划
- 421浏览 收藏
-
- 文章 · python教程 | 5小时前 | 数据校验 · python · Python Pydantic field_validator model_validator 联合约束
- Python Pydantic怎样对多个字段实施联合约束
- 210浏览 收藏
-
- 文章 · python教程 | 5小时前 | Python Pydantic After field_validator before
- Python Pydantic字段校验器before与after怎么选择
- 469浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- PubMedQA
- 深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
- 463次使用
-
- H2O EvalGPT
- H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
- 526次使用
-
- LMArena
- LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
- 545次使用
-
- HELM
- 深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
- 493次使用
-
- MMBench
- MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
- 313次使用
-
- Python sqlite3 Connection serialize 怎么导出数据库快照:备份窗口、内存占用与恢复校验
- 2026-08-26 501浏览
-
- Python监控网页状态:requests异常处理实战
- 2026-05-29 501浏览
-
- TensorFlow模型部署为API的TF Serving方法
- 2026-05-26 501浏览
-
- Python字符串编码转换:encode与decode详解
- 2026-05-16 501浏览
-
- TensorFlow裁剪无用算子方法详解
- 2026-05-15 501浏览

