如何将 Azure 机器学习批量评分结果写入数据湖？

Question

我正在尝试将批量评分的输出写入数据湖：

    parallel_step_name = "batchscoring-" + datetime.now().strftime("%Y%m%d%H%M")
    
    output_dir = PipelineData(name="scores", 
                              datastore=def_ADL_store,
                              output_mode="upload",
                              output_path_on_compute="path in data lake")

parallel_run_config = ParallelRunConfig(
    environment=curated_environment,
    entry_script="use_model.py",
    source_directory="./",
    output_action="append_row",
    mini_batch_size="20",
    error_threshold=1,
    compute_target=compute_target,
    process_count_per_node=2,
    node_count=2
)
    
    batch_score_step = ParallelRunStep(
        name=parallel_step_name,
        inputs=[test_data.as_named_input("test_data")],
        output=output_dir,
        parallel_run_config=parallel_run_config,
        allow_reuse=False
    )

但是我遇到错误：“code”：“UserError”， “消息”：“用户程序失败并出现异常：缺少参数 -- 输出或其值为空。”

如何将批量评分结果写入数据湖？

Answer 1

我认为 PipelineData 不支持 ADLS。我的建议是为 PipelineData 使用工作区的默认 blob 存储，然后在 ParallelRunStep 完成后使用 DataTransferStep。

如何将 Azure 机器学习批量评分结果写入数据湖？

How to write Azure machine learning batch scoring results to data lake?

azure-data-lake

azure-machine-learning-service