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

Question

我在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开始呢？是否有一些可以运行它的网址？

Answer 1

您可以使用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)