Skip to content

Commit

Permalink
Implement Get All Measure for DataLakeMeasureApi
Browse files Browse the repository at this point in the history
  • Loading branch information
wyyolo committed Jan 27, 2024
1 parent 6b82469 commit ab91631
Showing 1 changed file with 1 addition and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -39,9 +39,7 @@ func NewDataLakeMeasureApi(clientConfig config.StreamPipesClientConnectionConfig
}

func (api *DataLakeMeasureApi) All() []resource.DataLakeMeasure {
//这里出问题了,第一行的baseurl不空,第二行就空了
//api.GetRequest = StreamPipesHttp.NewGetRequest(api.config, api.GetRequest.Serializer)
api.ResourcePath() //先新建再调用。
api.ResourcePath()
api.getRequest.ExecuteGetRequest(api.serializer.UnSerializerDataLakeMeasure)
return *api.serializer.UnSerializerDataLakeMeasure
}
Expand Down Expand Up @@ -74,14 +72,4 @@ func (d *DataLakeMeasureApi) ResourcePath() {

slice := []string{"api", "v4", "datalake", "measurements"}
d.getRequest.HttpRequest.MakeUrl(slice)
//fmt.Println(d.GetRequest.HttpRequest.Url, 766765756)
//fmt.Println(d.GetRequest.HttpRequest.ApiPath.PathItems)
//return d.GetRequest.HttpRequest.MakeUrl(slice)
//d.GetRequest.HttpRequest.ApiPath.AddToPath(slice).ToString()
//fmt.Println(d.GetRequest.HttpRequest.ApiPath.PathItems)
}

//都在java的api文件里,三个文件中包含了这些方法,getall等等。
//看java似乎是定义了三个序列化器,getall是序列化成[]string类型。getsingle是序列化数据成一个对象,应该是获取单个数据的意思
//在python中,lake部分只有get,post,all,三个功能,而且all是获取所有的资源数据,不支持获取一条
//有一个大问题就是,要搞清楚访问streampipes的路径

0 comments on commit ab91631

Please sign in to comment.