pyspark 使用Azure数据库从Azure数据工厂查询管道运行Spark Python获得意外的关键字参数“continuation_token”

nbysray5  于 2023-03-17  发布在  Spark
关注(0)|答案(1)|浏览(166)

我正在尝试使用Azure数据构件从Azure数据工厂查询管道运行,我发现这个线程正是我所需要的。
How to get next Page of ADF Pipeline run details using continuation_token in Azure Data Factory - Databricks?
按照答案1中的说明,我得到了相同的错误消息:
request() got an unexpected keyword argument 'continuation_token'
参数的名称是否更改?

pipeline_runs = adf_client.pipeline_runs.query_by_factory(resource_group_name=rg_name, 
                                                              factory_name=df_name, 
                                                              filter_parameters=filter_params) 
while pipeline_runs.continuation_token:
    
    print(len(pipeline_runs.value))

    pipeline_runs = adf_client.pipeline_runs.query_by_factory(resource_group_name=rg_name, 
                                                              factory_name=df_name, 
                                                              filter_parameters=filter_params, 
                                                              continuation_token=pipeline_runs.continuation_token)
enyaitl3

enyaitl31#

这对我很有效:
过滤器参数=型号.运行过滤器参数(上次更新后=上次更新后,上次更新前=上次更新前,延续令牌=列表管道.延续令牌)page2=adf客户端.管道运行.按工厂查询(资源组名称=资源组名称,工厂名称=工厂名称,过滤器参数=过滤器参数)

相关问题