请问在机器学习PAI里,哪里可以找到原始数据集转换成parquet的代码?[阿里云机器学习PAI]

modelzoo里面提供的淘宝数据集只有几M(https://github.com/DeepRec-AI/DeepRec/blob/main/modelzoo/esmm/README.md#prepare),天池上面原始数据集有几个G(https://tianchi.aliyun.com/dataset/408),请问在机器学习PAI里,哪里可以找到原始数据集转换成parquet的代码?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
2 条回复 A 作者 M 管理员
  1. 在阿里云机器学习PAI中,转换原始数据集为Parquet格式的代码可以通过生成PAI-DSW项目的方式实现。您可以按照以下步骤完成:

    1. 登录阿里云机器学习控制台,创建一个PAI-DSW项目。

    2. 在PAI-DSW项目中找到parquet部分的示例代码,这个示例代码涉及了将数据从csv格式转为parquet格式的过程,您可以参考这个示例代码,对数据格式进行相应调整。

    3. 下载淘宝数据集的原始数据,按照适当的格式存储到您的PAI-DSW项目中。

    4. 将您编写的代码上传至PAI-DSW项目,并执行代码。在转换过程中,如果遇到任何错误,可以通过查看相应的日志或调试信息来对代码进行优化和调整。

    数据规模较大时,转换过程可能比较耗时,建议您尽可能利用分布式计算和其他优化方法,来提高转换效率和效果。

  2. 在机器学习平台PAI中,您可以使用Spark将原始数据集转换为Parquet格式。具体步骤如下:

    准备工作:将原始数据集上传到 PAI 文件系统中。

    在 PAI 控制台上创建一个新的 Spark 任务,并选择您要使用的 Spark 版本和配置。

    在任务脚本中使用 Spark SQL API 将原始数据集转换为 Parquet 格式,并将结果保存到指定路径中。以下是 Python 示例代码:

    from pyspark.sql import SparkSession

    创建 SparkSession 对象

    spark = SparkSession.builder.appName(“ConvertToParquet”).getOrCreate()

    读取原始数据集

    df = spark.read.format(“<原始数据集文件格式>“).load(“<原始数据集路径>“)

    执行数据转换操作

    将转换结果保存为 Parquet 格式

    df.write.format(“parquet”).save(““) 其中,<原始数据集文件格式> 代表原始数据集所使用的文件格式,例如 CSV、JSON、ORC 等;<原始数据集路径> 是原始数据集在 PAI 文件系统中的路径; 是转换后的 Parquet 文件在 PAI 文件系统中的路径。

    注意:在执行数据转换操作之前,您需要根据实际需求对数据进行清洗、预处理等操作。同时,您还需要根据数据集的规模和特点来调整Spark的配置参数,以确保任务能够正常运行。

  3. 我给你一个例子。https://github.com/JackMoriarty/DatasetConversionTools/blob/main/taobao/csv_price_int32_to_parquet.py 此回答整理自钉群“DeepRec用户群”