v1

package
v0.0.86 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 28, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenReqDefForAddDevData 

func GenReqDefForAddDevData() *def.HttpRequestDef

func GenReqDefForAddPipelineJob 

func GenReqDefForAddPipelineJob() *def.HttpRequestDef

func GenReqDefForCreateAssetModel 

func GenReqDefForCreateAssetModel() *def.HttpRequestDef

func GenReqDefForCreateAssetNew 

func GenReqDefForCreateAssetNew() *def.HttpRequestDef

func GenReqDefForCreateBatchJob 

func GenReqDefForCreateBatchJob() *def.HttpRequestDef

func GenReqDefForCreateComputingResource 

func GenReqDefForCreateComputingResource() *def.HttpRequestDef

func GenReqDefForCreateDatasource 

func GenReqDefForCreateDatasource() *def.HttpRequestDef

func GenReqDefForCreateGroup 

func GenReqDefForCreateGroup() *def.HttpRequestDef

func GenReqDefForCreateRun 

func GenReqDefForCreateRun() *def.HttpRequestDef

func GenReqDefForCreateStreamingJob 

func GenReqDefForCreateStreamingJob() *def.HttpRequestDef

func GenReqDefForCreateTable 

func GenReqDefForCreateTable() *def.HttpRequestDef

func GenReqDefForDeleteAssetModel 

func GenReqDefForDeleteAssetModel() *def.HttpRequestDef

func GenReqDefForDeleteAssetNew 

func GenReqDefForDeleteAssetNew() *def.HttpRequestDef

func GenReqDefForDeleteBatchJob 

func GenReqDefForDeleteBatchJob() *def.HttpRequestDef

func GenReqDefForDeleteComputingResource 

func GenReqDefForDeleteComputingResource() *def.HttpRequestDef

func GenReqDefForDeleteDataStore 

func GenReqDefForDeleteDataStore() *def.HttpRequestDef

func GenReqDefForDeleteDatasource 

func GenReqDefForDeleteDatasource() *def.HttpRequestDef

func GenReqDefForDeleteGroup 

func GenReqDefForDeleteGroup() *def.HttpRequestDef

func GenReqDefForDeletePipelineJob 

func GenReqDefForDeletePipelineJob() *def.HttpRequestDef

func GenReqDefForDeleteRun 

func GenReqDefForDeleteRun() *def.HttpRequestDef

func GenReqDefForDeleteStreamingJobById 

func GenReqDefForDeleteStreamingJobById() *def.HttpRequestDef

func GenReqDefForDeleteTable 

func GenReqDefForDeleteTable() *def.HttpRequestDef

func GenReqDefForExportDataset 

func GenReqDefForExportDataset() *def.HttpRequestDef

func GenReqDefForImportData 

func GenReqDefForImportData() *def.HttpRequestDef

func GenReqDefForListAssetModels 

func GenReqDefForListAssetModels() *def.HttpRequestDef

func GenReqDefForListAssetsNew 

func GenReqDefForListAssetsNew() *def.HttpRequestDef

func GenReqDefForListBatchJobs 

func GenReqDefForListBatchJobs() *def.HttpRequestDef

func GenReqDefForListComputingResources 

func GenReqDefForListComputingResources() *def.HttpRequestDef

func GenReqDefForListDataStores 

func GenReqDefForListDataStores() *def.HttpRequestDef

func GenReqDefForListGroups 

func GenReqDefForListGroups() *def.HttpRequestDef

func GenReqDefForListHistory 

func GenReqDefForListHistory() *def.HttpRequestDef

func GenReqDefForListMetrics 

func GenReqDefForListMetrics() *def.HttpRequestDef

func GenReqDefForListPipelineJobs 

func GenReqDefForListPipelineJobs() *def.HttpRequestDef

func GenReqDefForListRuns 

func GenReqDefForListRuns() *def.HttpRequestDef

func GenReqDefForListTables 

func GenReqDefForListTables() *def.HttpRequestDef

func GenReqDefForListTagValues 

func GenReqDefForListTagValues() *def.HttpRequestDef

func GenReqDefForPublishRootAsset 

func GenReqDefForPublishRootAsset() *def.HttpRequestDef

func GenReqDefForShowAllDataSource 

func GenReqDefForShowAllDataSource() *def.HttpRequestDef

func GenReqDefForShowAssetModel 

func GenReqDefForShowAssetModel() *def.HttpRequestDef

func GenReqDefForShowAssetNew 

func GenReqDefForShowAssetNew() *def.HttpRequestDef

func GenReqDefForShowBatchJob 

func GenReqDefForShowBatchJob() *def.HttpRequestDef

func GenReqDefForShowDataSource 

func GenReqDefForShowDataSource() *def.HttpRequestDef

func GenReqDefForShowDataset 

func GenReqDefForShowDataset() *def.HttpRequestDef

func GenReqDefForShowJobById 

func GenReqDefForShowJobById() *def.HttpRequestDef

func GenReqDefForShowJobs 

func GenReqDefForShowJobs() *def.HttpRequestDef

func GenReqDefForShowLastPropertyValue 

func GenReqDefForShowLastPropertyValue() *def.HttpRequestDef

func GenReqDefForShowMetricValue 

func GenReqDefForShowMetricValue() *def.HttpRequestDef

func GenReqDefForShowPipelineJob 

func GenReqDefForShowPipelineJob() *def.HttpRequestDef

func GenReqDefForShowPropertyRawValue 

func GenReqDefForShowPropertyRawValue() *def.HttpRequestDef

func GenReqDefForShowPropertyValues 

func GenReqDefForShowPropertyValues() *def.HttpRequestDef

func GenReqDefForShowRun 

func GenReqDefForShowRun() *def.HttpRequestDef

func GenReqDefForShowTablePreview 

func GenReqDefForShowTablePreview() *def.HttpRequestDef

func GenReqDefForShowTableSchema 

func GenReqDefForShowTableSchema() *def.HttpRequestDef

func GenReqDefForStartJob 

func GenReqDefForStartJob() *def.HttpRequestDef

func GenReqDefForStartPipelineJob 

func GenReqDefForStartPipelineJob() *def.HttpRequestDef

func GenReqDefForStopJob 

func GenReqDefForStopJob() *def.HttpRequestDef

func GenReqDefForStopPipelineJob 

func GenReqDefForStopPipelineJob() *def.HttpRequestDef

func GenReqDefForUpdateAssetModel 

func GenReqDefForUpdateAssetModel() *def.HttpRequestDef

func GenReqDefForUpdateAssetNew 

func GenReqDefForUpdateAssetNew() *def.HttpRequestDef

func GenReqDefForUpdateBatchJob 

func GenReqDefForUpdateBatchJob() *def.HttpRequestDef

func GenReqDefForUpdateDataSource 

func GenReqDefForUpdateDataSource() *def.HttpRequestDef

func GenReqDefForUpdateDataStore 

func GenReqDefForUpdateDataStore() *def.HttpRequestDef

func GenReqDefForUpdateGroup 

func GenReqDefForUpdateGroup() *def.HttpRequestDef

func GenReqDefForUpdatePipelineJob 

func GenReqDefForUpdatePipelineJob() *def.HttpRequestDef

func GenReqDefForUpdateStreamingJob 

func GenReqDefForUpdateStreamingJob() *def.HttpRequestDef

func GenReqDefForValidateSql 

func GenReqDefForValidateSql() *def.HttpRequestDef

func IoTAnalyticsClientBuilder 

func IoTAnalyticsClientBuilder() *http_client.HcHttpClientBuilder

Types

type IoTAnalyticsClient 

type IoTAnalyticsClient struct {
	HcClient *http_client.HcHttpClient
}

func NewIoTAnalyticsClient 

func NewIoTAnalyticsClient(hcClient *http_client.HcHttpClient) *IoTAnalyticsClient

func (*IoTAnalyticsClient) AddDevData 

func (c *IoTAnalyticsClient) AddDevData(request *model.AddDevDataRequest) (*model.AddDevDataResponse, error)

通过API数据源上报设备数据

通过API数据源上报设备数据

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) AddPipelineJob 

func (c *IoTAnalyticsClient) AddPipelineJob(request *model.AddPipelineJobRequest) (*model.AddPipelineJobResponse, error)

新建管道作业

新建管道作业时，需要在URL中指定是更新哪一个作业，将在body中附带完整的作业信息。（作业中各算子的详细配置请参考算子配置章节。） check参数表示是否需要对作业配置进行检查，若为false，则不检查，将作业保存为草稿；若为true，则对作业配置进行检查。当检查不通过时，将作业状态修改为草稿；检查通过时，将作业状态修改为就绪，并返回成功。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateAssetModel 

func (c *IoTAnalyticsClient) CreateAssetModel(request *model.CreateAssetModelRequest) (*model.CreateAssetModelResponse, error)

创建资产模型

创建资产模型

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateAssetNew 

func (c *IoTAnalyticsClient) CreateAssetNew(request *model.CreateAssetNewRequest) (*model.CreateAssetNewResponse, error)

创建资产

创建资产

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateBatchJob 

func (c *IoTAnalyticsClient) CreateBatchJob(request *model.CreateBatchJobRequest) (*model.CreateBatchJobResponse, error)

创建离线作业

创建离线作业。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateComputingResource 

func (c *IoTAnalyticsClient) CreateComputingResource(request *model.CreateComputingResourceRequest) (*model.CreateComputingResourceResponse, error)

创建批计算资源

创建批计算资源。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateDatasource 

func (c *IoTAnalyticsClient) CreateDatasource(request *model.CreateDatasourceRequest) (*model.CreateDatasourceResponse, error)

创建数据源

创建数据源

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateGroup 

func (c *IoTAnalyticsClient) CreateGroup(request *model.CreateGroupRequest) (*model.CreateGroupResponse, error)

创建存储组

创建存储组

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateRun 

func (c *IoTAnalyticsClient) CreateRun(request *model.CreateRunRequest) (*model.CreateRunResponse, error)

执行离线作业

执行离线作业。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateStreamingJob 

func (c *IoTAnalyticsClient) CreateStreamingJob(request *model.CreateStreamingJobRequest) (*model.CreateStreamingJobResponse, error)

新建实时作业

除名称和描述外，可先不提供作业的详细配置信息。 check参数表示是否需要对作业配置进行检查，若为false，则不检查，将作业保存为草稿；若为true，则对作业配置进行检查，无论检查是否通过，都将作业及配置信息保存为草稿，当检查不通过时，返回失败及错误信息，检查通过时，将作业状态修改为就绪，并返回成功。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateTable 

func (c *IoTAnalyticsClient) CreateTable(request *model.CreateTableRequest) (*model.CreateTableResponse, error)

创建离线数据表

创建离线数据表。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteAssetModel 

func (c *IoTAnalyticsClient) DeleteAssetModel(request *model.DeleteAssetModelRequest) (*model.DeleteAssetModelResponse, error)

删除资产模型

删除资产模型

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteAssetNew 

func (c *IoTAnalyticsClient) DeleteAssetNew(request *model.DeleteAssetNewRequest) (*model.DeleteAssetNewResponse, error)

删除资产

删除资产

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteBatchJob 

func (c *IoTAnalyticsClient) DeleteBatchJob(request *model.DeleteBatchJobRequest) (*model.DeleteBatchJobResponse, error)

删除离线作业

删除离线作业。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteComputingResource 

func (c *IoTAnalyticsClient) DeleteComputingResource(request *model.DeleteComputingResourceRequest) (*model.DeleteComputingResourceResponse, error)

删除批计算资源

删除批计算资源。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteDataStore 

func (c *IoTAnalyticsClient) DeleteDataStore(request *model.DeleteDataStoreRequest) (*model.DeleteDataStoreResponse, error)

删除存储

删除存储

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteDatasource 

func (c *IoTAnalyticsClient) DeleteDatasource(request *model.DeleteDatasourceRequest) (*model.DeleteDatasourceResponse, error)

删除数据源

删除数据源

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteGroup 

func (c *IoTAnalyticsClient) DeleteGroup(request *model.DeleteGroupRequest) (*model.DeleteGroupResponse, error)

删除存储组

删除存储组

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeletePipelineJob 

func (c *IoTAnalyticsClient) DeletePipelineJob(request *model.DeletePipelineJobRequest) (*model.DeletePipelineJobResponse, error)

删除管道作业

删除用户指定的管道作业

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteRun 

func (c *IoTAnalyticsClient) DeleteRun(request *model.DeleteRunRequest) (*model.DeleteRunResponse, error)

停止离线作业

停止提交中或运行中的离线作业，若作业已经执行结束或失败则无法停止。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteStreamingJobById 

func (c *IoTAnalyticsClient) DeleteStreamingJobById(request *model.DeleteStreamingJobByIdRequest) (*model.DeleteStreamingJobByIdResponse, error)

删除实时作业

删除用户指定的作业

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteTable 

func (c *IoTAnalyticsClient) DeleteTable(request *model.DeleteTableRequest) (*model.DeleteTableResponse, error)

删除离线数据表

删除离线数据表。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ExportDataset 

func (c *IoTAnalyticsClient) ExportDataset(request *model.ExportDatasetRequest) (*model.ExportDatasetResponse, error)

下载离线作业结果

将SQL语句的查询结果下载到本地，只支持下载“QUERY”类型作业的查询结果。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ImportData 

func (c *IoTAnalyticsClient) ImportData(request *model.ImportDataRequest) (*model.ImportDataResponse, error)

执行导入数据离线作业

将数据从文件导入OBS表。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListAssetModels 

func (c *IoTAnalyticsClient) ListAssetModels(request *model.ListAssetModelsRequest) (*model.ListAssetModelsResponse, error)

获取资产模型列表

获取资产模型列表

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListAssetsNew 

func (c *IoTAnalyticsClient) ListAssetsNew(request *model.ListAssetsNewRequest) (*model.ListAssetsNewResponse, error)

获取资产列表

获取资产列表

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListBatchJobs 

func (c *IoTAnalyticsClient) ListBatchJobs(request *model.ListBatchJobsRequest) (*model.ListBatchJobsResponse, error)

查询离线作业列表

查询离线作业列表。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListComputingResources 

func (c *IoTAnalyticsClient) ListComputingResources(request *model.ListComputingResourcesRequest) (*model.ListComputingResourcesResponse, error)

查询批计算资源列表

查询批计算资源列表。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListDataStores 

func (c *IoTAnalyticsClient) ListDataStores(request *model.ListDataStoresRequest) (*model.ListDataStoresResponse, error)

查询存储列表

查询存储列表

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListGroups 

func (c *IoTAnalyticsClient) ListGroups(request *model.ListGroupsRequest) (*model.ListGroupsResponse, error)

查询存储组列表

查询存储组列表

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListHistory 

func (c *IoTAnalyticsClient) ListHistory(request *model.ListHistoryRequest) (*model.ListHistoryResponse, error)

根据标签查询设备历史值

根据标签查询设备历史值

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListMetrics 

func (c *IoTAnalyticsClient) ListMetrics(request *model.ListMetricsRequest) (*model.ListMetricsResponse, error)

根据标签聚合、查询指标数据

根据标签聚合、查询数据

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListPipelineJobs 

func (c *IoTAnalyticsClient) ListPipelineJobs(request *model.ListPipelineJobsRequest) (*model.ListPipelineJobsResponse, error)

获取管道作业列表

获取用户下的所有管道作业，支持分页。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListRuns 

func (c *IoTAnalyticsClient) ListRuns(request *model.ListRunsRequest) (*model.ListRunsResponse, error)

查询离线作业运行列表

查询离线作业运行列表。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListTables 

func (c *IoTAnalyticsClient) ListTables(request *model.ListTablesRequest) (*model.ListTablesResponse, error)

查询离线数据表列表

查询离线数据表列表。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ListTagValues 

func (c *IoTAnalyticsClient) ListTagValues(request *model.ListTagValuesRequest) (*model.ListTagValuesResponse, error)

查询标签的值列表

查询标签的值列表

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) PublishRootAsset 

func (c *IoTAnalyticsClient) PublishRootAsset(request *model.PublishRootAssetRequest) (*model.PublishRootAssetResponse, error)

发布资产

发布资产

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowAllDataSource 

func (c *IoTAnalyticsClient) ShowAllDataSource(request *model.ShowAllDataSourceRequest) (*model.ShowAllDataSourceResponse, error)

查询数据源列表

查询数据源列表

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowAssetModel 

func (c *IoTAnalyticsClient) ShowAssetModel(request *model.ShowAssetModelRequest) (*model.ShowAssetModelResponse, error)

获取资产模型详情

获取资产模型详情

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowAssetNew 

func (c *IoTAnalyticsClient) ShowAssetNew(request *model.ShowAssetNewRequest) (*model.ShowAssetNewResponse, error)

获取资产详情

获取资产详情

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowBatchJob 

func (c *IoTAnalyticsClient) ShowBatchJob(request *model.ShowBatchJobRequest) (*model.ShowBatchJobResponse, error)

查询离线作业详情

查询离线作业详情。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowDataSource 

func (c *IoTAnalyticsClient) ShowDataSource(request *model.ShowDataSourceRequest) (*model.ShowDataSourceResponse, error)

查询数据源详情

查询数据源详情

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowDataset 

func (c *IoTAnalyticsClient) ShowDataset(request *model.ShowDatasetRequest) (*model.ShowDatasetResponse, error)

查询离线作业结果

在执行SQL查询语句的作业完成后，查看该作业执行的结果。目前仅支持查看“QUERY”类型作业的执行结果。该API只能查看前1000条的结果记录，若要查看全部的结果记录，需要先导出查询结果再进行查看。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowJobById 

func (c *IoTAnalyticsClient) ShowJobById(request *model.ShowJobByIdRequest) (*model.ShowJobByIdResponse, error)

获取实时作业详情

获取指定作业的详情

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowJobs 

func (c *IoTAnalyticsClient) ShowJobs(request *model.ShowJobsRequest) (*model.ShowJobsResponse, error)

获取实时作业列表

获取用户下的所有实时分析作业，支持分页。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowLastPropertyValue 

func (c *IoTAnalyticsClient) ShowLastPropertyValue(request *model.ShowLastPropertyValueRequest) (*model.ShowLastPropertyValueResponse, error)

获取资产属性最新值

获取资产属性最新值

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowMetricValue 

func (c *IoTAnalyticsClient) ShowMetricValue(request *model.ShowMetricValueRequest) (*model.ShowMetricValueResponse, error)

获取资产属性聚合值

获取资产属性聚合值

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowPipelineJob 

func (c *IoTAnalyticsClient) ShowPipelineJob(request *model.ShowPipelineJobRequest) (*model.ShowPipelineJobResponse, error)

获取管道作业详情

获取指定管道作业的详情

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowPropertyRawValue 

func (c *IoTAnalyticsClient) ShowPropertyRawValue(request *model.ShowPropertyRawValueRequest) (*model.ShowPropertyRawValueResponse, error)

获取资产属性历史值

获取资产属性历史值

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowPropertyValues 

func (c *IoTAnalyticsClient) ShowPropertyValues(request *model.ShowPropertyValuesRequest) (*model.ShowPropertyValuesResponse, error)

查询设备属性最新状态值

查询设备属性最新状态值

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowRun 

func (c *IoTAnalyticsClient) ShowRun(request *model.ShowRunRequest) (*model.ShowRunResponse, error)

查询离线作业运行详情

查询离线作业运行详情。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowTablePreview 

func (c *IoTAnalyticsClient) ShowTablePreview(request *model.ShowTablePreviewRequest) (*model.ShowTablePreviewResponse, error)

预览离线数据表内容

预览离线数据表内容。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowTableSchema 

func (c *IoTAnalyticsClient) ShowTableSchema(request *model.ShowTableSchemaRequest) (*model.ShowTableSchemaResponse, error)

查询离线数据表结构

查询离线数据表结构。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) StartJob 

func (c *IoTAnalyticsClient) StartJob(request *model.StartJobRequest) (*model.StartJobResponse, error)

启动实时作业

提交作业到运行环境，实时接收数据并按用户定义的业务逻辑对数据进行处理。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) StartPipelineJob 

func (c *IoTAnalyticsClient) StartPipelineJob(request *model.StartPipelineJobRequest) (*model.StartPipelineJobResponse, error)

启动管道作业

提交管道作业到运行环境，实时接收数据源的数据并按用户定义的数据清洗逻辑对数据进行处理。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) StopJob 

func (c *IoTAnalyticsClient) StopJob(request *model.StopJobRequest) (*model.StopJobResponse, error)

停止实时作业

停止一个正在运行中的作业

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) StopPipelineJob 

func (c *IoTAnalyticsClient) StopPipelineJob(request *model.StopPipelineJobRequest) (*model.StopPipelineJobResponse, error)

停止管道作业

停止一个正在运行中的管道作业

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateAssetModel 

func (c *IoTAnalyticsClient) UpdateAssetModel(request *model.UpdateAssetModelRequest) (*model.UpdateAssetModelResponse, error)

修改资产模型

修改资产模型

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateAssetNew 

func (c *IoTAnalyticsClient) UpdateAssetNew(request *model.UpdateAssetNewRequest) (*model.UpdateAssetNewResponse, error)

修改资产

修改资产

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateBatchJob 

func (c *IoTAnalyticsClient) UpdateBatchJob(request *model.UpdateBatchJobRequest) (*model.UpdateBatchJobResponse, error)

修改离线作业

修改离线作业。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateDataSource 

func (c *IoTAnalyticsClient) UpdateDataSource(request *model.UpdateDataSourceRequest) (*model.UpdateDataSourceResponse, error)

修改数据源

修改数据源

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateDataStore 

func (c *IoTAnalyticsClient) UpdateDataStore(request *model.UpdateDataStoreRequest) (*model.UpdateDataStoreResponse, error)

更新存储

更新存储

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateGroup 

func (c *IoTAnalyticsClient) UpdateGroup(request *model.UpdateGroupRequest) (*model.UpdateGroupResponse, error)

更新存储组

更新存储组

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdatePipelineJob 

func (c *IoTAnalyticsClient) UpdatePipelineJob(request *model.UpdatePipelineJobRequest) (*model.UpdatePipelineJobResponse, error)

更新管道作业

更新管道作业时，需要在URL中指定是更新哪一个作业，将在body中附带完整的作业信息。（管道作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：数据管道算子配置指南。） check参数表示是否需要对作业配置进行检查，若为false，则不检查，将作业保存为草稿；若为true，则对作业配置进行检查。当检查不通过时，将作业状态修改为草稿；检查通过时，将作业状态修改为就绪，并返回成功。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateStreamingJob 

func (c *IoTAnalyticsClient) UpdateStreamingJob(request *model.UpdateStreamingJobRequest) (*model.UpdateStreamingJobResponse, error)

更新实时作业

更新作业时，需要在URL中指定是更新哪一个作业，将在body中附带完整的作业信息。 check参数表示是否需要对作业配置进行检查，若为false，则不检查，将作业保存为草稿；若为true，则对作业配置进行检查，无论检查是否通过，都将作业及配置信息保存为草稿，当检查不通过时，返回失败及错误信息，检查通过时，将作业状态修改为就绪，并返回成功。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*IoTAnalyticsClient) ValidateSql 

func (c *IoTAnalyticsClient) ValidateSql(request *model.ValidateSqlRequest) (*model.ValidateSqlResponse, error)

检查离线作业SQL语法

检查离线作业SQL语法。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.