google.appengine.api.files.shuffler 模块

总结

Files API。

自 1.8.1 版起已弃用：请改用 Google Cloud Storage 客户端库。

Files API Shuffler 接口

目录

google.appengine.api.files.shuffler.shuffle(job_name, input_file_list, output_file_list, callback)源代码

使用 shuffler 服务对 mapreduce 文件执行 shuffle 操作。

参数

  • job_name - 字符串形式的唯一 shuffle 作业。

  • input_file_list - 要对其执行 shuffle 操作的 Files API 文件名列表。文件应采用记录格式，其中包含序列化的 KeyValue 协议缓冲区作为记录。

  • output_file_list - 用于存储 shuffle 结果的 Files API 文件名列表。文件不应最终确定。文件采用记录格式，其中包含序列化的 KeyValue 协议缓冲区作为记录。

  • callback -

    shuffle 服务回调规范。可以是任一网址 - 使用默认参数的默认队列中的任务会加入队列。它也可以是包含以下键的字典：

    url：要回调的网址 version：要调用的应用版本 method：要使用的 HTTP 方法（POST 或 GET）queue：用于将任务加入队列的队列名称。

可能引发的错误

如果 shuffler 服务不可用，则系统会引发 ShufflerUnavailableError。

google.appengine.api.files.shuffler.available()源代码

确定 shuffler 服务是否可用于应用。

返回值

如果 shuffler 服务可用，则系统会返回 True，否则系统会返回 False。