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

我在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)

相关文章

我最近重新拾起了计算机视觉,借助Python的opencv还有face_r...
说到Pooling,相信学习过CNN的朋友们都不会感到陌生。Poolin...
记得大一学Python的时候,有一个题目是判断一个数是否是复数...
文章目录 3 直方图Histogramplot1. 基本直方图的绘制 Basic ...
文章目录 5 小提琴图Violinplot1. 基础小提琴图绘制 Basic v...
文章目录 4 核密度图Densityplot1. 基础核密度图绘制 Basic ...