如何在GAE Python上从cron启动mapreduce作业

发布时间：2020-12-16 22:18:06 所属栏目：Python 来源：网络整理

导读：我在mapreduce.yaml中定义了mapreduce作业： mapreduce:- name: JobName mapper: input_reader: google.appengine.ext.mapreduce.input_readers.DatastoreInputReader handler: handler_name params: - name: entity_kind default: KindName 如何从cron开始

我在mapreduce.yaml中定义了mapreduce作业：

mapreduce:
- name: JobName 
  mapper:
    input_reader: google.appengine.ext.mapreduce.input_readers.DatastoreInputReader
    handler: handler_name
    params:
    - name: entity_kind
      default: KindName

如何从cron开始呢？是否有一些可以运行它的网址？

最佳答案

您可以使用control.py从任何类型的AppEngine处理程序启动mapreduce任务

from mapreduce import control

mapreduce_id = control.start_map(
    "My Mapper","main.my_mapper","mapreduce.input_readers.DatastoreInputReader",{"entity_kind": "models.MyEntity"},shard_count=10)

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!