v1

package
v0.0.83 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 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

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

func (*IoTAnalyticsClient) AddPipelineJob

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

func (*IoTAnalyticsClient) CreateAssetModel

创建资产模型

func (*IoTAnalyticsClient) CreateAssetNew

创建资产

func (*IoTAnalyticsClient) CreateBatchJob

创建离线作业。

func (*IoTAnalyticsClient) CreateComputingResource

创建批计算资源。

func (*IoTAnalyticsClient) CreateDatasource

创建数据源

func (*IoTAnalyticsClient) CreateGroup

创建存储组

func (*IoTAnalyticsClient) CreateRun

执行离线作业。

func (*IoTAnalyticsClient) CreateStreamingJob

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

func (*IoTAnalyticsClient) CreateTable

创建离线数据表。

func (*IoTAnalyticsClient) DeleteAssetModel

删除资产模型

func (*IoTAnalyticsClient) DeleteAssetNew

删除资产

func (*IoTAnalyticsClient) DeleteBatchJob

删除离线作业。

func (*IoTAnalyticsClient) DeleteComputingResource

删除批计算资源。

func (*IoTAnalyticsClient) DeleteDataStore

删除存储

func (*IoTAnalyticsClient) DeleteDatasource

删除数据源

func (*IoTAnalyticsClient) DeleteGroup

删除存储组

func (*IoTAnalyticsClient) DeletePipelineJob

删除用户指定的管道作业

func (*IoTAnalyticsClient) DeleteRun

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

func (*IoTAnalyticsClient) DeleteStreamingJobById

删除用户指定的作业

func (*IoTAnalyticsClient) DeleteTable

删除离线数据表。

func (*IoTAnalyticsClient) ExportDataset

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

func (*IoTAnalyticsClient) ImportData

将数据从文件导入OBS表。

func (*IoTAnalyticsClient) ListAssetModels

获取资产模型列表

func (*IoTAnalyticsClient) ListAssetsNew

获取资产列表

func (*IoTAnalyticsClient) ListBatchJobs

查询离线作业列表。

func (*IoTAnalyticsClient) ListComputingResources

查询批计算资源列表。

func (*IoTAnalyticsClient) ListDataStores

查询存储列表

func (*IoTAnalyticsClient) ListGroups

查询存储组列表

func (*IoTAnalyticsClient) ListHistory

根据标签查询设备历史值

func (*IoTAnalyticsClient) ListMetrics

根据标签聚合、查询数据

func (*IoTAnalyticsClient) ListPipelineJobs

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

func (*IoTAnalyticsClient) ListRuns

查询离线作业运行列表。

func (*IoTAnalyticsClient) ListTables

查询离线数据表列表。

func (*IoTAnalyticsClient) ListTagValues

查询标签的值列表

func (*IoTAnalyticsClient) PublishRootAsset

发布资产

func (*IoTAnalyticsClient) ShowAllDataSource

查询数据源列表

func (*IoTAnalyticsClient) ShowAssetModel

获取资产模型详情

func (*IoTAnalyticsClient) ShowAssetNew

获取资产详情

func (*IoTAnalyticsClient) ShowBatchJob

查询离线作业详情。

func (*IoTAnalyticsClient) ShowDataSource

查询数据源详情

func (*IoTAnalyticsClient) ShowDataset

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

func (*IoTAnalyticsClient) ShowJobById

获取指定作业的详情

func (*IoTAnalyticsClient) ShowJobs

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

func (*IoTAnalyticsClient) ShowLastPropertyValue

获取资产属性最新值

func (*IoTAnalyticsClient) ShowMetricValue

获取资产属性聚合值

func (*IoTAnalyticsClient) ShowPipelineJob

获取指定管道作业的详情

func (*IoTAnalyticsClient) ShowPropertyRawValue

获取资产属性历史值

func (*IoTAnalyticsClient) ShowPropertyValues

查询设备属性最新状态值

func (*IoTAnalyticsClient) ShowRun

查询离线作业运行详情。

func (*IoTAnalyticsClient) ShowTablePreview

预览离线数据表内容。

func (*IoTAnalyticsClient) ShowTableSchema

查询离线数据表结构。

func (*IoTAnalyticsClient) StartJob

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

func (*IoTAnalyticsClient) StartPipelineJob

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

func (*IoTAnalyticsClient) StopJob

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

func (*IoTAnalyticsClient) StopPipelineJob

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

func (*IoTAnalyticsClient) UpdateAssetModel

修改资产模型

func (*IoTAnalyticsClient) UpdateAssetNew

修改资产

func (*IoTAnalyticsClient) UpdateBatchJob

修改离线作业。

func (*IoTAnalyticsClient) UpdateDataSource

修改数据源

func (*IoTAnalyticsClient) UpdateDataStore

更新存储

func (*IoTAnalyticsClient) UpdateGroup

更新存储组

func (*IoTAnalyticsClient) UpdatePipelineJob

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

func (*IoTAnalyticsClient) UpdateStreamingJob

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

func (*IoTAnalyticsClient) ValidateSql

检查离线作业SQL语法。

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL