Documentation ¶
Index ¶
- func GenReqDefForAddDevData() *def.HttpRequestDef
- func GenReqDefForAddPipelineJob() *def.HttpRequestDef
- func GenReqDefForCreateAssetModel() *def.HttpRequestDef
- func GenReqDefForCreateAssetNew() *def.HttpRequestDef
- func GenReqDefForCreateBatchJob() *def.HttpRequestDef
- func GenReqDefForCreateComputingResource() *def.HttpRequestDef
- func GenReqDefForCreateDatasource() *def.HttpRequestDef
- func GenReqDefForCreateGroup() *def.HttpRequestDef
- func GenReqDefForCreateRun() *def.HttpRequestDef
- func GenReqDefForCreateStreamingJob() *def.HttpRequestDef
- func GenReqDefForCreateTable() *def.HttpRequestDef
- func GenReqDefForDeleteAssetModel() *def.HttpRequestDef
- func GenReqDefForDeleteAssetNew() *def.HttpRequestDef
- func GenReqDefForDeleteBatchJob() *def.HttpRequestDef
- func GenReqDefForDeleteComputingResource() *def.HttpRequestDef
- func GenReqDefForDeleteDataStore() *def.HttpRequestDef
- func GenReqDefForDeleteDatasource() *def.HttpRequestDef
- func GenReqDefForDeleteGroup() *def.HttpRequestDef
- func GenReqDefForDeletePipelineJob() *def.HttpRequestDef
- func GenReqDefForDeleteRun() *def.HttpRequestDef
- func GenReqDefForDeleteStreamingJobById() *def.HttpRequestDef
- func GenReqDefForDeleteTable() *def.HttpRequestDef
- func GenReqDefForExportDataset() *def.HttpRequestDef
- func GenReqDefForImportData() *def.HttpRequestDef
- func GenReqDefForListAssetModels() *def.HttpRequestDef
- func GenReqDefForListAssetsNew() *def.HttpRequestDef
- func GenReqDefForListBatchJobs() *def.HttpRequestDef
- func GenReqDefForListComputingResources() *def.HttpRequestDef
- func GenReqDefForListDataStores() *def.HttpRequestDef
- func GenReqDefForListGroups() *def.HttpRequestDef
- func GenReqDefForListHistory() *def.HttpRequestDef
- func GenReqDefForListMetrics() *def.HttpRequestDef
- func GenReqDefForListPipelineJobs() *def.HttpRequestDef
- func GenReqDefForListRuns() *def.HttpRequestDef
- func GenReqDefForListTables() *def.HttpRequestDef
- func GenReqDefForListTagValues() *def.HttpRequestDef
- func GenReqDefForPublishRootAsset() *def.HttpRequestDef
- func GenReqDefForShowAllDataSource() *def.HttpRequestDef
- func GenReqDefForShowAssetModel() *def.HttpRequestDef
- func GenReqDefForShowAssetNew() *def.HttpRequestDef
- func GenReqDefForShowBatchJob() *def.HttpRequestDef
- func GenReqDefForShowDataSource() *def.HttpRequestDef
- func GenReqDefForShowDataset() *def.HttpRequestDef
- func GenReqDefForShowJobById() *def.HttpRequestDef
- func GenReqDefForShowJobs() *def.HttpRequestDef
- func GenReqDefForShowLastPropertyValue() *def.HttpRequestDef
- func GenReqDefForShowMetricValue() *def.HttpRequestDef
- func GenReqDefForShowPipelineJob() *def.HttpRequestDef
- func GenReqDefForShowPropertyRawValue() *def.HttpRequestDef
- func GenReqDefForShowPropertyValues() *def.HttpRequestDef
- func GenReqDefForShowRun() *def.HttpRequestDef
- func GenReqDefForShowTablePreview() *def.HttpRequestDef
- func GenReqDefForShowTableSchema() *def.HttpRequestDef
- func GenReqDefForStartJob() *def.HttpRequestDef
- func GenReqDefForStartPipelineJob() *def.HttpRequestDef
- func GenReqDefForStopJob() *def.HttpRequestDef
- func GenReqDefForStopPipelineJob() *def.HttpRequestDef
- func GenReqDefForUpdateAssetModel() *def.HttpRequestDef
- func GenReqDefForUpdateAssetNew() *def.HttpRequestDef
- func GenReqDefForUpdateBatchJob() *def.HttpRequestDef
- func GenReqDefForUpdateDataSource() *def.HttpRequestDef
- func GenReqDefForUpdateDataStore() *def.HttpRequestDef
- func GenReqDefForUpdateGroup() *def.HttpRequestDef
- func GenReqDefForUpdatePipelineJob() *def.HttpRequestDef
- func GenReqDefForUpdateStreamingJob() *def.HttpRequestDef
- func GenReqDefForValidateSql() *def.HttpRequestDef
- func IoTAnalyticsClientBuilder() *http_client.HcHttpClientBuilder
- type IoTAnalyticsClient
- func (c *IoTAnalyticsClient) AddDevData(request *model.AddDevDataRequest) (*model.AddDevDataResponse, error)
- func (c *IoTAnalyticsClient) AddPipelineJob(request *model.AddPipelineJobRequest) (*model.AddPipelineJobResponse, error)
- func (c *IoTAnalyticsClient) CreateAssetModel(request *model.CreateAssetModelRequest) (*model.CreateAssetModelResponse, error)
- func (c *IoTAnalyticsClient) CreateAssetNew(request *model.CreateAssetNewRequest) (*model.CreateAssetNewResponse, error)
- func (c *IoTAnalyticsClient) CreateBatchJob(request *model.CreateBatchJobRequest) (*model.CreateBatchJobResponse, error)
- func (c *IoTAnalyticsClient) CreateComputingResource(request *model.CreateComputingResourceRequest) (*model.CreateComputingResourceResponse, error)
- func (c *IoTAnalyticsClient) CreateDatasource(request *model.CreateDatasourceRequest) (*model.CreateDatasourceResponse, error)
- func (c *IoTAnalyticsClient) CreateGroup(request *model.CreateGroupRequest) (*model.CreateGroupResponse, error)
- func (c *IoTAnalyticsClient) CreateRun(request *model.CreateRunRequest) (*model.CreateRunResponse, error)
- func (c *IoTAnalyticsClient) CreateStreamingJob(request *model.CreateStreamingJobRequest) (*model.CreateStreamingJobResponse, error)
- func (c *IoTAnalyticsClient) CreateTable(request *model.CreateTableRequest) (*model.CreateTableResponse, error)
- func (c *IoTAnalyticsClient) DeleteAssetModel(request *model.DeleteAssetModelRequest) (*model.DeleteAssetModelResponse, error)
- func (c *IoTAnalyticsClient) DeleteAssetNew(request *model.DeleteAssetNewRequest) (*model.DeleteAssetNewResponse, error)
- func (c *IoTAnalyticsClient) DeleteBatchJob(request *model.DeleteBatchJobRequest) (*model.DeleteBatchJobResponse, error)
- func (c *IoTAnalyticsClient) DeleteComputingResource(request *model.DeleteComputingResourceRequest) (*model.DeleteComputingResourceResponse, error)
- func (c *IoTAnalyticsClient) DeleteDataStore(request *model.DeleteDataStoreRequest) (*model.DeleteDataStoreResponse, error)
- func (c *IoTAnalyticsClient) DeleteDatasource(request *model.DeleteDatasourceRequest) (*model.DeleteDatasourceResponse, error)
- func (c *IoTAnalyticsClient) DeleteGroup(request *model.DeleteGroupRequest) (*model.DeleteGroupResponse, error)
- func (c *IoTAnalyticsClient) DeletePipelineJob(request *model.DeletePipelineJobRequest) (*model.DeletePipelineJobResponse, error)
- func (c *IoTAnalyticsClient) DeleteRun(request *model.DeleteRunRequest) (*model.DeleteRunResponse, error)
- func (c *IoTAnalyticsClient) DeleteStreamingJobById(request *model.DeleteStreamingJobByIdRequest) (*model.DeleteStreamingJobByIdResponse, error)
- func (c *IoTAnalyticsClient) DeleteTable(request *model.DeleteTableRequest) (*model.DeleteTableResponse, error)
- func (c *IoTAnalyticsClient) ExportDataset(request *model.ExportDatasetRequest) (*model.ExportDatasetResponse, error)
- func (c *IoTAnalyticsClient) ImportData(request *model.ImportDataRequest) (*model.ImportDataResponse, error)
- func (c *IoTAnalyticsClient) ListAssetModels(request *model.ListAssetModelsRequest) (*model.ListAssetModelsResponse, error)
- func (c *IoTAnalyticsClient) ListAssetsNew(request *model.ListAssetsNewRequest) (*model.ListAssetsNewResponse, error)
- func (c *IoTAnalyticsClient) ListBatchJobs(request *model.ListBatchJobsRequest) (*model.ListBatchJobsResponse, error)
- func (c *IoTAnalyticsClient) ListComputingResources(request *model.ListComputingResourcesRequest) (*model.ListComputingResourcesResponse, error)
- func (c *IoTAnalyticsClient) ListDataStores(request *model.ListDataStoresRequest) (*model.ListDataStoresResponse, error)
- func (c *IoTAnalyticsClient) ListGroups(request *model.ListGroupsRequest) (*model.ListGroupsResponse, error)
- func (c *IoTAnalyticsClient) ListHistory(request *model.ListHistoryRequest) (*model.ListHistoryResponse, error)
- func (c *IoTAnalyticsClient) ListMetrics(request *model.ListMetricsRequest) (*model.ListMetricsResponse, error)
- func (c *IoTAnalyticsClient) ListPipelineJobs(request *model.ListPipelineJobsRequest) (*model.ListPipelineJobsResponse, error)
- func (c *IoTAnalyticsClient) ListRuns(request *model.ListRunsRequest) (*model.ListRunsResponse, error)
- func (c *IoTAnalyticsClient) ListTables(request *model.ListTablesRequest) (*model.ListTablesResponse, error)
- func (c *IoTAnalyticsClient) ListTagValues(request *model.ListTagValuesRequest) (*model.ListTagValuesResponse, error)
- func (c *IoTAnalyticsClient) PublishRootAsset(request *model.PublishRootAssetRequest) (*model.PublishRootAssetResponse, error)
- func (c *IoTAnalyticsClient) ShowAllDataSource(request *model.ShowAllDataSourceRequest) (*model.ShowAllDataSourceResponse, error)
- func (c *IoTAnalyticsClient) ShowAssetModel(request *model.ShowAssetModelRequest) (*model.ShowAssetModelResponse, error)
- func (c *IoTAnalyticsClient) ShowAssetNew(request *model.ShowAssetNewRequest) (*model.ShowAssetNewResponse, error)
- func (c *IoTAnalyticsClient) ShowBatchJob(request *model.ShowBatchJobRequest) (*model.ShowBatchJobResponse, error)
- func (c *IoTAnalyticsClient) ShowDataSource(request *model.ShowDataSourceRequest) (*model.ShowDataSourceResponse, error)
- func (c *IoTAnalyticsClient) ShowDataset(request *model.ShowDatasetRequest) (*model.ShowDatasetResponse, error)
- func (c *IoTAnalyticsClient) ShowJobById(request *model.ShowJobByIdRequest) (*model.ShowJobByIdResponse, error)
- func (c *IoTAnalyticsClient) ShowJobs(request *model.ShowJobsRequest) (*model.ShowJobsResponse, error)
- func (c *IoTAnalyticsClient) ShowLastPropertyValue(request *model.ShowLastPropertyValueRequest) (*model.ShowLastPropertyValueResponse, error)
- func (c *IoTAnalyticsClient) ShowMetricValue(request *model.ShowMetricValueRequest) (*model.ShowMetricValueResponse, error)
- func (c *IoTAnalyticsClient) ShowPipelineJob(request *model.ShowPipelineJobRequest) (*model.ShowPipelineJobResponse, error)
- func (c *IoTAnalyticsClient) ShowPropertyRawValue(request *model.ShowPropertyRawValueRequest) (*model.ShowPropertyRawValueResponse, error)
- func (c *IoTAnalyticsClient) ShowPropertyValues(request *model.ShowPropertyValuesRequest) (*model.ShowPropertyValuesResponse, error)
- func (c *IoTAnalyticsClient) ShowRun(request *model.ShowRunRequest) (*model.ShowRunResponse, error)
- func (c *IoTAnalyticsClient) ShowTablePreview(request *model.ShowTablePreviewRequest) (*model.ShowTablePreviewResponse, error)
- func (c *IoTAnalyticsClient) ShowTableSchema(request *model.ShowTableSchemaRequest) (*model.ShowTableSchemaResponse, error)
- func (c *IoTAnalyticsClient) StartJob(request *model.StartJobRequest) (*model.StartJobResponse, error)
- func (c *IoTAnalyticsClient) StartPipelineJob(request *model.StartPipelineJobRequest) (*model.StartPipelineJobResponse, error)
- func (c *IoTAnalyticsClient) StopJob(request *model.StopJobRequest) (*model.StopJobResponse, error)
- func (c *IoTAnalyticsClient) StopPipelineJob(request *model.StopPipelineJobRequest) (*model.StopPipelineJobResponse, error)
- func (c *IoTAnalyticsClient) UpdateAssetModel(request *model.UpdateAssetModelRequest) (*model.UpdateAssetModelResponse, error)
- func (c *IoTAnalyticsClient) UpdateAssetNew(request *model.UpdateAssetNewRequest) (*model.UpdateAssetNewResponse, error)
- func (c *IoTAnalyticsClient) UpdateBatchJob(request *model.UpdateBatchJobRequest) (*model.UpdateBatchJobResponse, error)
- func (c *IoTAnalyticsClient) UpdateDataSource(request *model.UpdateDataSourceRequest) (*model.UpdateDataSourceResponse, error)
- func (c *IoTAnalyticsClient) UpdateDataStore(request *model.UpdateDataStoreRequest) (*model.UpdateDataStoreResponse, error)
- func (c *IoTAnalyticsClient) UpdateGroup(request *model.UpdateGroupRequest) (*model.UpdateGroupResponse, error)
- func (c *IoTAnalyticsClient) UpdatePipelineJob(request *model.UpdatePipelineJobRequest) (*model.UpdatePipelineJobResponse, error)
- func (c *IoTAnalyticsClient) UpdateStreamingJob(request *model.UpdateStreamingJobRequest) (*model.UpdateStreamingJobResponse, error)
- func (c *IoTAnalyticsClient) ValidateSql(request *model.ValidateSqlRequest) (*model.ValidateSqlResponse, error)
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数据源上报设备数据
func (*IoTAnalyticsClient) AddPipelineJob ¶
func (c *IoTAnalyticsClient) AddPipelineJob(request *model.AddPipelineJobRequest) (*model.AddPipelineJobResponse, error)
新建管道作业时,需要在URL中指定是更新哪一个作业,将在body中附带完整的作业信息。(作业中各算子的详细配置请参考算子配置章节。) check参数表示是否需要对作业配置进行检查,若为false,则不检查,将作业保存为草稿;若为true,则对作业配置进行检查。当检查不通过时,将作业状态修改为草稿;检查通过时,将作业状态修改为就绪,并返回成功。
func (*IoTAnalyticsClient) CreateAssetModel ¶
func (c *IoTAnalyticsClient) CreateAssetModel(request *model.CreateAssetModelRequest) (*model.CreateAssetModelResponse, error)
创建资产模型
func (*IoTAnalyticsClient) CreateAssetNew ¶
func (c *IoTAnalyticsClient) CreateAssetNew(request *model.CreateAssetNewRequest) (*model.CreateAssetNewResponse, error)
创建资产
func (*IoTAnalyticsClient) CreateBatchJob ¶
func (c *IoTAnalyticsClient) CreateBatchJob(request *model.CreateBatchJobRequest) (*model.CreateBatchJobResponse, error)
创建离线作业。
func (*IoTAnalyticsClient) CreateComputingResource ¶
func (c *IoTAnalyticsClient) CreateComputingResource(request *model.CreateComputingResourceRequest) (*model.CreateComputingResourceResponse, error)
创建批计算资源。
func (*IoTAnalyticsClient) CreateDatasource ¶
func (c *IoTAnalyticsClient) CreateDatasource(request *model.CreateDatasourceRequest) (*model.CreateDatasourceResponse, error)
创建数据源
func (*IoTAnalyticsClient) CreateGroup ¶
func (c *IoTAnalyticsClient) CreateGroup(request *model.CreateGroupRequest) (*model.CreateGroupResponse, error)
创建存储组
func (*IoTAnalyticsClient) CreateRun ¶
func (c *IoTAnalyticsClient) CreateRun(request *model.CreateRunRequest) (*model.CreateRunResponse, error)
执行离线作业。
func (*IoTAnalyticsClient) CreateStreamingJob ¶
func (c *IoTAnalyticsClient) CreateStreamingJob(request *model.CreateStreamingJobRequest) (*model.CreateStreamingJobResponse, error)
除名称和描述外,可先不提供作业的详细配置信息。 check参数表示是否需要对作业配置进行检查,若为false,则不检查,将作业保存为草稿;若为true,则对作业配置进行检查,无论检查是否通过,都将作业及配置信息保存为草稿,当检查不通过时,返回失败及错误信息,检查通过时,将作业状态修改为就绪,并返回成功。
func (*IoTAnalyticsClient) CreateTable ¶
func (c *IoTAnalyticsClient) CreateTable(request *model.CreateTableRequest) (*model.CreateTableResponse, error)
创建离线数据表。
func (*IoTAnalyticsClient) DeleteAssetModel ¶
func (c *IoTAnalyticsClient) DeleteAssetModel(request *model.DeleteAssetModelRequest) (*model.DeleteAssetModelResponse, error)
删除资产模型
func (*IoTAnalyticsClient) DeleteAssetNew ¶
func (c *IoTAnalyticsClient) DeleteAssetNew(request *model.DeleteAssetNewRequest) (*model.DeleteAssetNewResponse, error)
删除资产
func (*IoTAnalyticsClient) DeleteBatchJob ¶
func (c *IoTAnalyticsClient) DeleteBatchJob(request *model.DeleteBatchJobRequest) (*model.DeleteBatchJobResponse, error)
删除离线作业。
func (*IoTAnalyticsClient) DeleteComputingResource ¶
func (c *IoTAnalyticsClient) DeleteComputingResource(request *model.DeleteComputingResourceRequest) (*model.DeleteComputingResourceResponse, error)
删除批计算资源。
func (*IoTAnalyticsClient) DeleteDataStore ¶
func (c *IoTAnalyticsClient) DeleteDataStore(request *model.DeleteDataStoreRequest) (*model.DeleteDataStoreResponse, error)
删除存储
func (*IoTAnalyticsClient) DeleteDatasource ¶
func (c *IoTAnalyticsClient) DeleteDatasource(request *model.DeleteDatasourceRequest) (*model.DeleteDatasourceResponse, error)
删除数据源
func (*IoTAnalyticsClient) DeleteGroup ¶
func (c *IoTAnalyticsClient) DeleteGroup(request *model.DeleteGroupRequest) (*model.DeleteGroupResponse, error)
删除存储组
func (*IoTAnalyticsClient) DeletePipelineJob ¶
func (c *IoTAnalyticsClient) DeletePipelineJob(request *model.DeletePipelineJobRequest) (*model.DeletePipelineJobResponse, error)
删除用户指定的管道作业
func (*IoTAnalyticsClient) DeleteRun ¶
func (c *IoTAnalyticsClient) DeleteRun(request *model.DeleteRunRequest) (*model.DeleteRunResponse, error)
停止提交中或运行中的离线作业,若作业已经执行结束或失败则无法停止。
func (*IoTAnalyticsClient) DeleteStreamingJobById ¶
func (c *IoTAnalyticsClient) DeleteStreamingJobById(request *model.DeleteStreamingJobByIdRequest) (*model.DeleteStreamingJobByIdResponse, error)
删除用户指定的作业
func (*IoTAnalyticsClient) DeleteTable ¶
func (c *IoTAnalyticsClient) DeleteTable(request *model.DeleteTableRequest) (*model.DeleteTableResponse, error)
删除离线数据表。
func (*IoTAnalyticsClient) ExportDataset ¶
func (c *IoTAnalyticsClient) ExportDataset(request *model.ExportDatasetRequest) (*model.ExportDatasetResponse, error)
将SQL语句的查询结果下载到本地,只支持下载“QUERY”类型作业的查询结果。
func (*IoTAnalyticsClient) ImportData ¶
func (c *IoTAnalyticsClient) ImportData(request *model.ImportDataRequest) (*model.ImportDataResponse, error)
将数据从文件导入OBS表。
func (*IoTAnalyticsClient) ListAssetModels ¶
func (c *IoTAnalyticsClient) ListAssetModels(request *model.ListAssetModelsRequest) (*model.ListAssetModelsResponse, error)
获取资产模型列表
func (*IoTAnalyticsClient) ListAssetsNew ¶
func (c *IoTAnalyticsClient) ListAssetsNew(request *model.ListAssetsNewRequest) (*model.ListAssetsNewResponse, error)
获取资产列表
func (*IoTAnalyticsClient) ListBatchJobs ¶
func (c *IoTAnalyticsClient) ListBatchJobs(request *model.ListBatchJobsRequest) (*model.ListBatchJobsResponse, error)
查询离线作业列表。
func (*IoTAnalyticsClient) ListComputingResources ¶
func (c *IoTAnalyticsClient) ListComputingResources(request *model.ListComputingResourcesRequest) (*model.ListComputingResourcesResponse, error)
查询批计算资源列表。
func (*IoTAnalyticsClient) ListDataStores ¶
func (c *IoTAnalyticsClient) ListDataStores(request *model.ListDataStoresRequest) (*model.ListDataStoresResponse, error)
查询存储列表
func (*IoTAnalyticsClient) ListGroups ¶
func (c *IoTAnalyticsClient) ListGroups(request *model.ListGroupsRequest) (*model.ListGroupsResponse, error)
查询存储组列表
func (*IoTAnalyticsClient) ListHistory ¶
func (c *IoTAnalyticsClient) ListHistory(request *model.ListHistoryRequest) (*model.ListHistoryResponse, error)
根据标签查询设备历史值
func (*IoTAnalyticsClient) ListMetrics ¶
func (c *IoTAnalyticsClient) ListMetrics(request *model.ListMetricsRequest) (*model.ListMetricsResponse, error)
根据标签聚合、查询数据
func (*IoTAnalyticsClient) ListPipelineJobs ¶
func (c *IoTAnalyticsClient) ListPipelineJobs(request *model.ListPipelineJobsRequest) (*model.ListPipelineJobsResponse, error)
获取用户下的所有管道作业,支持分页。
func (*IoTAnalyticsClient) ListRuns ¶
func (c *IoTAnalyticsClient) ListRuns(request *model.ListRunsRequest) (*model.ListRunsResponse, error)
查询离线作业运行列表。
func (*IoTAnalyticsClient) ListTables ¶
func (c *IoTAnalyticsClient) ListTables(request *model.ListTablesRequest) (*model.ListTablesResponse, error)
查询离线数据表列表。
func (*IoTAnalyticsClient) ListTagValues ¶
func (c *IoTAnalyticsClient) ListTagValues(request *model.ListTagValuesRequest) (*model.ListTagValuesResponse, error)
查询标签的值列表
func (*IoTAnalyticsClient) PublishRootAsset ¶
func (c *IoTAnalyticsClient) PublishRootAsset(request *model.PublishRootAssetRequest) (*model.PublishRootAssetResponse, error)
发布资产
func (*IoTAnalyticsClient) ShowAllDataSource ¶
func (c *IoTAnalyticsClient) ShowAllDataSource(request *model.ShowAllDataSourceRequest) (*model.ShowAllDataSourceResponse, error)
查询数据源列表
func (*IoTAnalyticsClient) ShowAssetModel ¶
func (c *IoTAnalyticsClient) ShowAssetModel(request *model.ShowAssetModelRequest) (*model.ShowAssetModelResponse, error)
获取资产模型详情
func (*IoTAnalyticsClient) ShowAssetNew ¶
func (c *IoTAnalyticsClient) ShowAssetNew(request *model.ShowAssetNewRequest) (*model.ShowAssetNewResponse, error)
获取资产详情
func (*IoTAnalyticsClient) ShowBatchJob ¶
func (c *IoTAnalyticsClient) ShowBatchJob(request *model.ShowBatchJobRequest) (*model.ShowBatchJobResponse, error)
查询离线作业详情。
func (*IoTAnalyticsClient) ShowDataSource ¶
func (c *IoTAnalyticsClient) ShowDataSource(request *model.ShowDataSourceRequest) (*model.ShowDataSourceResponse, error)
查询数据源详情
func (*IoTAnalyticsClient) ShowDataset ¶
func (c *IoTAnalyticsClient) ShowDataset(request *model.ShowDatasetRequest) (*model.ShowDatasetResponse, error)
在执行SQL查询语句的作业完成后,查看该作业执行的结果。目前仅支持查看“QUERY”类型作业的执行结果。该API只能查看前1000条的结果记录,若要查看全部的结果记录,需要先导出查询结果再进行查看。
func (*IoTAnalyticsClient) ShowJobById ¶
func (c *IoTAnalyticsClient) ShowJobById(request *model.ShowJobByIdRequest) (*model.ShowJobByIdResponse, error)
获取指定作业的详情
func (*IoTAnalyticsClient) ShowJobs ¶
func (c *IoTAnalyticsClient) ShowJobs(request *model.ShowJobsRequest) (*model.ShowJobsResponse, error)
获取用户下的所有实时分析作业,支持分页。
func (*IoTAnalyticsClient) ShowLastPropertyValue ¶
func (c *IoTAnalyticsClient) ShowLastPropertyValue(request *model.ShowLastPropertyValueRequest) (*model.ShowLastPropertyValueResponse, error)
获取资产属性最新值
func (*IoTAnalyticsClient) ShowMetricValue ¶
func (c *IoTAnalyticsClient) ShowMetricValue(request *model.ShowMetricValueRequest) (*model.ShowMetricValueResponse, error)
获取资产属性聚合值
func (*IoTAnalyticsClient) ShowPipelineJob ¶
func (c *IoTAnalyticsClient) ShowPipelineJob(request *model.ShowPipelineJobRequest) (*model.ShowPipelineJobResponse, error)
获取指定管道作业的详情
func (*IoTAnalyticsClient) ShowPropertyRawValue ¶
func (c *IoTAnalyticsClient) ShowPropertyRawValue(request *model.ShowPropertyRawValueRequest) (*model.ShowPropertyRawValueResponse, error)
获取资产属性历史值
func (*IoTAnalyticsClient) ShowPropertyValues ¶
func (c *IoTAnalyticsClient) ShowPropertyValues(request *model.ShowPropertyValuesRequest) (*model.ShowPropertyValuesResponse, error)
查询设备属性最新状态值
func (*IoTAnalyticsClient) ShowRun ¶
func (c *IoTAnalyticsClient) ShowRun(request *model.ShowRunRequest) (*model.ShowRunResponse, error)
查询离线作业运行详情。
func (*IoTAnalyticsClient) ShowTablePreview ¶
func (c *IoTAnalyticsClient) ShowTablePreview(request *model.ShowTablePreviewRequest) (*model.ShowTablePreviewResponse, error)
预览离线数据表内容。
func (*IoTAnalyticsClient) ShowTableSchema ¶
func (c *IoTAnalyticsClient) ShowTableSchema(request *model.ShowTableSchemaRequest) (*model.ShowTableSchemaResponse, error)
查询离线数据表结构。
func (*IoTAnalyticsClient) StartJob ¶
func (c *IoTAnalyticsClient) StartJob(request *model.StartJobRequest) (*model.StartJobResponse, error)
提交作业到运行环境,实时接收数据并按用户定义的业务逻辑对数据进行处理。
func (*IoTAnalyticsClient) StartPipelineJob ¶
func (c *IoTAnalyticsClient) StartPipelineJob(request *model.StartPipelineJobRequest) (*model.StartPipelineJobResponse, error)
提交管道作业到运行环境,实时接收数据源的数据并按用户定义的数据清洗逻辑对数据进行处理。
func (*IoTAnalyticsClient) StopJob ¶
func (c *IoTAnalyticsClient) StopJob(request *model.StopJobRequest) (*model.StopJobResponse, error)
停止一个正在运行中的作业
func (*IoTAnalyticsClient) StopPipelineJob ¶
func (c *IoTAnalyticsClient) StopPipelineJob(request *model.StopPipelineJobRequest) (*model.StopPipelineJobResponse, error)
停止一个正在运行中的管道作业
func (*IoTAnalyticsClient) UpdateAssetModel ¶
func (c *IoTAnalyticsClient) UpdateAssetModel(request *model.UpdateAssetModelRequest) (*model.UpdateAssetModelResponse, error)
修改资产模型
func (*IoTAnalyticsClient) UpdateAssetNew ¶
func (c *IoTAnalyticsClient) UpdateAssetNew(request *model.UpdateAssetNewRequest) (*model.UpdateAssetNewResponse, error)
修改资产
func (*IoTAnalyticsClient) UpdateBatchJob ¶
func (c *IoTAnalyticsClient) UpdateBatchJob(request *model.UpdateBatchJobRequest) (*model.UpdateBatchJobResponse, error)
修改离线作业。
func (*IoTAnalyticsClient) UpdateDataSource ¶
func (c *IoTAnalyticsClient) UpdateDataSource(request *model.UpdateDataSourceRequest) (*model.UpdateDataSourceResponse, error)
修改数据源
func (*IoTAnalyticsClient) UpdateDataStore ¶
func (c *IoTAnalyticsClient) UpdateDataStore(request *model.UpdateDataStoreRequest) (*model.UpdateDataStoreResponse, error)
更新存储
func (*IoTAnalyticsClient) UpdateGroup ¶
func (c *IoTAnalyticsClient) UpdateGroup(request *model.UpdateGroupRequest) (*model.UpdateGroupResponse, error)
更新存储组
func (*IoTAnalyticsClient) UpdatePipelineJob ¶
func (c *IoTAnalyticsClient) UpdatePipelineJob(request *model.UpdatePipelineJobRequest) (*model.UpdatePipelineJobResponse, error)
更新管道作业时,需要在URL中指定是更新哪一个作业,将在body中附带完整的作业信息。(管道作业详细配置,每个作业可选择不同的算子进行组合,各算子的使用方法详见:数据管道算子配置指南。) check参数表示是否需要对作业配置进行检查,若为false,则不检查,将作业保存为草稿;若为true,则对作业配置进行检查。当检查不通过时,将作业状态修改为草稿;检查通过时,将作业状态修改为就绪,并返回成功。
func (*IoTAnalyticsClient) UpdateStreamingJob ¶
func (c *IoTAnalyticsClient) UpdateStreamingJob(request *model.UpdateStreamingJobRequest) (*model.UpdateStreamingJobResponse, error)
更新作业时,需要在URL中指定是更新哪一个作业,将在body中附带完整的作业信息。 check参数表示是否需要对作业配置进行检查,若为false,则不检查,将作业保存为草稿;若为true,则对作业配置进行检查,无论检查是否通过,都将作业及配置信息保存为草稿,当检查不通过时,返回失败及错误信息,检查通过时,将作业状态修改为就绪,并返回成功。
func (*IoTAnalyticsClient) ValidateSql ¶
func (c *IoTAnalyticsClient) ValidateSql(request *model.ValidateSqlRequest) (*model.ValidateSqlResponse, error)
检查离线作业SQL语法。