파이썬 내가 아주 간단한 맵리 듀스 파이프 라인을 만든 맵리 듀스

Question

AppEngine에, 그러나 나는 비밀을 데 :

PipelineSetupError: Error starting production.cron.pipelines.ItemsInfoPipeline(*(), **{})#a741186284ed4fb8a4cd06e38921beff:

내가 그것을 시작하려고하면. 내가 두 번 매퍼 경로를 잘임을 확인하고, 내가이 파이프 라인은 어떤 일이 일어나고되지 않으며, 시작이 집중하고 있기 때문에 ItemsInfoStorePipeline 아무것도 안하고 고려했다

물론

class ItemsInfoPipeline(base_handler.PipelineBase): 
""" 
""" 

    def run(self): 
     output = yield mapreduce_pipeline.MapreducePipeline(
      job_name="items_job", 
      mapper_spec="production.cron.mappers.items_info_mapper", 
      input_reader_spec="mapreduce.input_readers.DatastoreInputReader", 
      mapper_params={ 
       "input_reader": { 
        "entity_kind": "production.models.Transaction" 
       } 
      } 
     ) 

     yield ItemsInfoStorePipeline(output) 


class ItemsInfoStorePipeline(base_handler.PipelineBase): 
""" 
""" 

    def run(self, statistics): 
     print statistics 
     return "OK" 

: 이것은 파이프 라인 코드 . 내가 어떤 도움을 GoogleAppEngineMapReduce==1.9.22.0

감사를 사용하고

class ItemsInfoMRJob(views.MethodView): 
""" 

It's based on transacions. 

""" 

    def get(self): 
    """ 

    :return: 
    """ 
     pipeline = ItemsInfoPipeline() 
     pipeline.start() 

     redirect_url = "%s/status?root=%s" % (pipeline.base_path, pipeline.pipeline_id) 

     return flask.redirect(redirect_url) 

다음

그것은 모든 플라스크보기에 의해 트리거됩니다. 위의 코드는 한 번에 배치 작품

UPDATE.

업데이트 2

은 분명히이 다루는 더 많은 사람들이있다 :이 업데이트하고 있습니다

https://github.com/GoogleCloudPlatform/appengine-mapreduce/issues/103

Answer 1

. 나는 파이프 라인을 사용하고 OSX에서 잘 작동하는 코드 기반을 가지고있다.

ProtoRPC 메소드 구현에서 발생했습니다 예기치 않은 오류 : PipelineSetupError

나는 주위 버전을 교환 시도하고 나는 그가이 도착, 내가 단순히 아무것도가 작업을 얻을 것 같다 OSX를 사용하여 다른 개발자가 있었다 우리의 PC 경기를 완벽하게 만들어 주며 계속해서 일어납니다. 나는 마침내 부서졌고 우분투 이미지를 도커에 만들었습니다. AppEngine과 라이브러리의 버전을 완벽하게 일치시키기 위해 최선을 다하고 있습니다.

또한 동일한 메시지로 시작하는 것을 거부합니다. 나는 오류를 삼키는 부분을 언급하지 않은 채 라이브러리를 작업하기 시작했습니다. 그러나 그 위의 많은 것들이 계속 진행되고 있기 때문에 시작된 긴 토끼 구멍이었습니다.