model

package
v0.0.99 Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddDevDataRequest 

type AddDevDataRequest struct {

	// 数据源id
	DatasourceId string `json:"datasource_id"`

	Body *interface{} `json:"body,omitempty"`
}

Request Object

func (AddDevDataRequest) String 

func (o AddDevDataRequest) String() string

type AddDevDataResponse 

type AddDevDataResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (AddDevDataResponse) String 

func (o AddDevDataResponse) String() string

type AddPipelineJobRequest 

type AddPipelineJobRequest struct {

	// 是否需要校验配置是否正确
	Check *bool `json:"check,omitempty"`

	// 管道作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：数据管道算子配置指南。
	Body map[string]interface{} `json:"body,omitempty"`
}

Request Object

func (AddPipelineJobRequest) String 

func (o AddPipelineJobRequest) String() string

type AddPipelineJobResponse 

type AddPipelineJobResponse struct {

	// 管道ID
	PipelineId *string `json:"pipeline_id,omitempty"`

	// 管道错误详情
	CheckInfo      map[string]interface{} `json:"check_info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (AddPipelineJobResponse) String 

func (o AddPipelineJobResponse) String() string

type AggregateMetric 

type AggregateMetric struct {

	// 声明属性作为表达式参数
	Inputs []InputParam `json:"inputs"`

	// 指标名称
	MetricName string `json:"metric_name"`

	// 表达式
	Expression string `json:"expression"`
}

查询指标

func (AggregateMetric) String 

func (o AggregateMetric) String() string

type AggregateMetrics 

type AggregateMetrics struct {
	TimeSpan *TimeSpan `json:"time_span"`

	// 聚合时间间隔, 示例：\"1d|1h|10m|10s\"
	Interval *string `json:"interval,omitempty"`

	// 聚合时间偏移量, 需要小于interval, 示例： \"1h|10m|10s\"
	Offset *string `json:"offset,omitempty"`

	// 对property按指定tags标签进行过滤查询，填入设备标签与标签值，不可为空，例如 {\"deviceId\": \"id0001\"}
	Tags map[string]string `json:"tags"`

	// 查询的测量指标列表
	Metrics []AggregateMetric `json:"metrics"`

	// 返回值个数限制
	Limit *int32 `json:"limit,omitempty"`
}

聚合计算定义

func (AggregateMetrics) String 

func (o AggregateMetrics) String() string

type AggregateMetricsRequest 

type AggregateMetricsRequest struct {
	TimeSpan *TimeSpanDt `json:"time_span,omitempty"`

	// 聚合时间间隔，正则：\"^[1-9][0-9]*[dhms]$\"，示例：\"1d|1h|10m|10s\"
	Interval string `json:"interval"`

	// 聚合时间偏移量，需要小于interval，正则： \"^[1-9][0-9]*[hms]$\"，示例： \"1h|10m|10s\"
	Offset *string `json:"offset,omitempty"`

	// 对property按指定tags标签进行过滤查询，填入资产标签属性的属性名与属性值，不可为空，例如 {\"tagPropertyA\": \"id0001\"}；注意，标签过滤只对打上标签时刻之后的数据生效，打标签之前的数据不能通过标签过滤
	Tags map[string]interface{} `json:"tags,omitempty"`

	// 属性过滤器，最多5个
	PropertyFilter *[]PropertyFilter `json:"property_filter,omitempty"`

	// 聚合查询指标列表，对资产属性进行聚合查询得到指标
	Metrics []DtAggregateMetrics `json:"metrics"`

	// 返回值个数限制，最多2000个
	Limit *int32 `json:"limit,omitempty"`
}

查询经过聚合计算的序列值定义

func (AggregateMetricsRequest) String 

func (o AggregateMetricsRequest) String() string

type AggregateModel 

type AggregateModel struct {

	// 输入参数，最多支持10个
	Inputs []InputModel `json:"inputs"`

	Expression *Expression `json:"expression"`

	Schedule *DtSchedule `json:"schedule"`

	// 输出属性名(分析任务单输出场景，配合expression的formula使用)
	OutputProperty *string `json:"output_property,omitempty"`

	// 输出属性，最多支持10个
	Outputs *[]OutputWithModel `json:"outputs,omitempty"`
}

聚合计算

func (AggregateModel) String 

func (o AggregateModel) String() string

type AggregateResponse 

type AggregateResponse struct {

	// 输入参数
	Inputs *[]InputResponse `json:"inputs,omitempty"`

	Expression *Expression `json:"expression,omitempty"`

	// 输出属性名(不推荐使用，待废弃，使用outputs替代)
	OutputProperty *string `json:"output_property,omitempty"`

	Outputs *[]OutputResponse `json:"outputs,omitempty"`

	Schedule *DtSchedule `json:"schedule,omitempty"`
}

聚合计算

func (AggregateResponse) String 

func (o AggregateResponse) String() string

type AnalysisModelRequest 

type AnalysisModelRequest struct {

	// 分析任务名称，正则：\"^[a-zA-Z][a-zA-Z0-9_]{0,63}$\"
	Name string `json:"name"`

	// 分析任务显示名称，正则：\"^[\\\\u4E00-\\\\u9FA5A-Za-z0-9_@#.-]{1,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 分析任务类型，转换计算（transform）、聚合计算（aggregate）、流计算（stream）
	Type string `json:"type"`

	Transform *TransformModel `json:"transform,omitempty"`

	Aggregate *AggregateModel `json:"aggregate,omitempty"`

	Stream *StreamModel `json:"stream,omitempty"`
}

分析任务

func (AnalysisModelRequest) String 

func (o AnalysisModelRequest) String() string

type AnalysisModelResponse 

type AnalysisModelResponse struct {

	// 分析任务名称，正则：\"^[a-zA-Z][a-zA-Z0-9_]{0,63}$\"
	Name string `json:"name"`

	// 分析任务显示名称，正则：\"^[\\\\u4E00-\\\\u9FA5A-Za-z0-9_@#.-]{1,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 分析任务类型，转换计算（transform）、聚合计算（aggregate）、流计算（stream）
	Type string `json:"type"`

	Transform *TransformModel `json:"transform,omitempty"`

	Aggregate *AggregateModel `json:"aggregate,omitempty"`

	Stream *StreamModel `json:"stream,omitempty"`

	// 分析任务ID
	AnalysisId *string `json:"analysis_id,omitempty"`
}

func (AnalysisModelResponse) String 

func (o AnalysisModelResponse) String() string

type AnalysisRequest 

type AnalysisRequest struct {

	// 分析任务名，必须是模型中已存在的
	Name string `json:"name"`

	Transform *DtTransformRequest `json:"transform,omitempty"`

	Aggregate *DtAggregateRequest `json:"aggregate,omitempty"`

	Stream *DtStreamRequest `json:"stream,omitempty"`
}

分析任务

func (AnalysisRequest) String 

func (o AnalysisRequest) String() string

type AnalysisResponse 

type AnalysisResponse struct {

	// 分析任务ID
	AnalysisId *string `json:"analysis_id,omitempty"`

	// 分析任务名称
	Name *string `json:"name,omitempty"`

	// 分析任务显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 分析任务类型，转换计算（transform）、聚合计算（aggregate）、流计算（stream）
	Type *string `json:"type,omitempty"`

	Transform *TransformResponse `json:"transform,omitempty"`

	Aggregate *AggregateResponse `json:"aggregate,omitempty"`

	Stream *StreamResponse `json:"stream,omitempty"`
}

func (AnalysisResponse) String 

func (o AnalysisResponse) String() string

type ApiContentReq 

type ApiContentReq struct {

	// api数据源名称
	Name string `json:"name"`
}

Api数据源请求内容

func (ApiContentReq) String 

func (o ApiContentReq) String() string

type ApiContentRsp 

type ApiContentRsp struct {

	// 数据源名称
	Name *string `json:"name,omitempty"`

	// 数据上报url
	Url *string `json:"url,omitempty"`
}

API数据源配置内容

func (ApiContentRsp) String 

func (o ApiContentRsp) String() string

type AssetAddRequest 

type AssetAddRequest struct {

	// 资产模型ID
	AssetModelId string `json:"asset_model_id"`

	// 资产名称，正则：\"^[a-zA-Z][a-zA-Z0-9_-]{0,63}$\"
	Name string `json:"name"`

	// 资产显示名称，修改资产时，\"\"代表配置为空、null或不携带代表不修改，正则：\"^[\\\\u4E-\\\\u9FA5A-Za-z0-9_@#.-]{0,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 父资产ID，根资产的父资产ID为null，修改资产时，null或不携带代表不修改
	Parent *string `json:"parent,omitempty"`

	// 属性集，最多200个
	Properties *[]PropertyRequest `json:"properties,omitempty"`

	// 分析任务集，最多50个
	Analyses *[]AnalysisRequest `json:"analyses,omitempty"`
}

func (AssetAddRequest) String 

func (o AssetAddRequest) String() string

type AssetModRequest 

type AssetModRequest struct {

	// 资产名称，修改资产时，null或不携带代表不修改，正则：\"^[a-zA-Z][a-zA-Z0-9_-]{0,63}$\"
	Name *string `json:"name,omitempty"`

	// 资产显示名称，修改资产时，\"\"代表配置为空、null或不携带代表不修改，正则：\"^[\\\\u4E00-\\\\u9FA5A-Za-z0-9_@#.-]{0,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 父资产ID，根资产的父资产ID为null，修改资产时，null或不携带代表不修改
	Parent *string `json:"parent,omitempty"`

	// 属性集，最多200个
	Properties *[]PropertyRequest `json:"properties,omitempty"`

	// 分析任务集，最多50个
	Analyses *[]AnalysisRequest `json:"analyses,omitempty"`
}

func (AssetModRequest) String 

func (o AssetModRequest) String() string

type AssetModelAddRequest 

type AssetModelAddRequest struct {

	// 模型名称，正则：\"^[a-zA-Z][a-zA-Z0-9_-]{0,63}$\"
	Name string `json:"name"`

	// 模型显示名称，正则：\"^[\\\\u4E00-\\\\u9FA5A-Za-z0-9_@#.-]{1,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集，最多200个
	Properties *[]PropertyModelRequest `json:"properties,omitempty"`

	// 分析任务集，最多50个
	Analyses *[]AnalysisModelRequest `json:"analyses,omitempty"`
}

func (AssetModelAddRequest) String 

func (o AssetModelAddRequest) String() string

type AssetModelModRequest 

type AssetModelModRequest struct {

	// 模型显示名称，正则：\"^[\\\\u4E00-\\\\u9FA5A-Za-z0-9_@#.-]{1,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集，最多200个
	Properties *[]PropertyModelRequest `json:"properties,omitempty"`

	// 分析任务集，最多50个
	Analyses *[]AnalysisModelRequest `json:"analyses,omitempty"`
}

func (AssetModelModRequest) String 

func (o AssetModelModRequest) String() string

type AssetModelResponse 

type AssetModelResponse struct {

	// 模型ID
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 模型名称
	Name *string `json:"name,omitempty"`

	// 模型显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集
	Properties *[]PropertyModelResponse `json:"properties,omitempty"`

	// 分析任务集
	Analyses *[]AnalysisModelResponse `json:"analyses,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime *string `json:"modified_time,omitempty"`
}

func (AssetModelResponse) String 

func (o AssetModelResponse) String() string

type AssetPropertyLastValue 

type AssetPropertyLastValue struct {

	// 资产属性名称
	PropertyName *string `json:"property_name,omitempty"`

	// 资产属性值
	Value *interface{} `json:"value,omitempty"`

	// 资产属性值最后更新时间
	Timestamp *string `json:"timestamp,omitempty"`
}

func (AssetPropertyLastValue) String 

func (o AssetPropertyLastValue) String() string

type AssetResponse 

type AssetResponse struct {

	// 资产ID
	AssetId *string `json:"asset_id,omitempty"`

	// 资产模型ID
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 资产模型名称
	AssetModelName *string `json:"asset_model_name,omitempty"`

	// 资产名称
	Name *string `json:"name,omitempty"`

	// 资产显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集
	Properties *[]PropertyResponse `json:"properties,omitempty"`

	// 分析任务集
	Analyses *[]AnalysisResponse `json:"analyses,omitempty"`

	// 根资产ID
	Root *string `json:"root,omitempty"`

	// 父资产ID，根资产的父资产ID为null
	Parent *string `json:"parent,omitempty"`

	// 子资产ID集
	Children *[]string `json:"children,omitempty"`

	// 资产状态，正常状态（ACTIVE），异常状态（INACTIVE）；只有草稿态（SKETCH）资产有此状态；资产处于异常状态的场景有：1、该资产存在未填写设备ID的测量数据类别的属性；2、该资产存在未填写静态值的静态配置类别的属性；3、该资产存在分析任务，该分析任务的输入参数存在属性引用类型为引用其他资产属性，且没有为该输入参数配置引用的其他资产的资产ID
	State *string `json:"state,omitempty"`

	// 资产发布状态，发布中（PUBLISHING），发布完成（PUBLISHED）；只能对草稿态（SKETCH）的根资产进行发布，也只有草稿态的根资产有此字段；如果根资产从未发布过则值为null
	PublishState *string `json:"publish_state,omitempty"`

	// 创建时间，格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间，格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 发布时间，只能对草稿态（SKETCH）的根资产进行发布，也只有草稿态的根资产有此字段；如果从未发布过则值为null；格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	PublishedTime *string `json:"published_time,omitempty"`
}

func (AssetResponse) String 

func (o AssetResponse) String() string

type Column 

type Column struct {

	// 列名称。
	ColumnName string `json:"column_name"`

	// 列描述。
	Description *string `json:"description,omitempty"`

	// 列类型。
	Type string `json:"type"`

	// 是否分区列。
	IsPartitionColumn *bool `json:"is_partition_column,omitempty"`
}

func (Column) String 

func (o Column) String() string

type ComputingResource 

type ComputingResource struct {

	// 计算资源ID。
	ComputingResourceId *string `json:"computing_resource_id,omitempty"`

	// 计算资源名称。
	ComputingResourceName *string `json:"computing_resource_name,omitempty"`

	// 计算资源描述信息。
	Description *string `json:"description,omitempty"`

	// 创建计算资源的用户。
	Owner *string `json:"owner,omitempty"`

	// 创建计算资源的时间。时间格式为ISO日期时间格式yyyy-MM-dd'T'HH:mm:ss'Z'
	CreatedTime *string `json:"created_time,omitempty"`

	// 计算资源的类型,。目前支持：sql
	ComputingResourceType *string `json:"computing_resource_type,omitempty"`

	// 与该计算资源绑定的计算单元数。设置值当前只支持16，64，256。
	CuCount *int32 `json:"cu_count,omitempty"`

	// 计算资源的收费模式。“1”表示按照CU时收费。“2”表示按照包年包月收费。
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// 计算资源类型。0：共享资源 1：专属资源
	ResourceMode *int32 `json:"resource_mode,omitempty"`
}

func (ComputingResource) String 

func (o ComputingResource) String() string

type ContentDetailReq 

type ContentDetailReq struct {
	IotdaContent *IotdaContentReq `json:"iotda_content,omitempty"`

	ObsContent *ObsContentReq `json:"obs_content,omitempty"`

	DisContent *DisContentReq `json:"dis_content,omitempty"`

	SmnContent *SmnContentReq `json:"smn_content,omitempty"`

	FunctionGraphContent *FunctionGraphContentReq `json:"function_graph_content,omitempty"`

	ModelArtsContent *ModelArtsContentReq `json:"model_arts_content,omitempty"`

	DcsContent *DcsContentReq `json:"dcs_content,omitempty"`

	KafkaContent *KafkaContentReq `json:"kafka_content,omitempty"`

	ApiContent *ApiContentReq `json:"api_content,omitempty"`

	NodeContent *NodeContentReq `json:"node_content,omitempty"`

	EdgeContent *EdgeContentReq `json:"edge_content,omitempty"`
}

IoTA服务各类数据源详细配置内容

func (ContentDetailReq) String 

func (o ContentDetailReq) String() string

type ContentDetailRsp 

type ContentDetailRsp struct {
	IotdaContent *IotdaContentRsp `json:"iotda_content,omitempty"`

	ObsContent *ObsContentRsp `json:"obs_content,omitempty"`

	DisContent *DisContentRsp `json:"dis_content,omitempty"`

	SmnContent *SmnContentRsp `json:"smn_content,omitempty"`

	FunctionGraphContent *FunctionGraphContentRsp `json:"function_graph_content,omitempty"`

	ModelArtsContent *ModelArtsContentRsp `json:"model_arts_content,omitempty"`

	DcsContent *DcsContentRsp `json:"dcs_content,omitempty"`

	KafkaContent *KafkaContentRsp `json:"kafka_content,omitempty"`

	ApiContent *ApiContentRsp `json:"api_content,omitempty"`

	NodeContent *NodeContentRsp `json:"node_content,omitempty"`

	EdgeContent *EdgeContentRsp `json:"edge_content,omitempty"`
}

IoTA服务各类数据源详细配置内容

func (ContentDetailRsp) String 

func (o ContentDetailRsp) String() string

type CreateAssetModelRequest 

type CreateAssetModelRequest struct {
	Body *AssetModelAddRequest `json:"body,omitempty"`
}

Request Object

func (CreateAssetModelRequest) String 

func (o CreateAssetModelRequest) String() string

type CreateAssetModelResponse 

type CreateAssetModelResponse struct {

	// 模型ID
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 模型名称
	Name *string `json:"name,omitempty"`

	// 模型显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集
	Properties *[]PropertyModelResponse `json:"properties,omitempty"`

	// 分析任务集
	Analyses *[]AnalysisModelResponse `json:"analyses,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateAssetModelResponse) String 

func (o CreateAssetModelResponse) String() string

type CreateAssetNewRequest 

type CreateAssetNewRequest struct {
	Body *AssetAddRequest `json:"body,omitempty"`
}

Request Object

func (CreateAssetNewRequest) String 

func (o CreateAssetNewRequest) String() string

type CreateAssetNewResponse 

type CreateAssetNewResponse struct {

	// 资产ID
	AssetId *string `json:"asset_id,omitempty"`

	// 资产模型ID
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 资产模型名称
	AssetModelName *string `json:"asset_model_name,omitempty"`

	// 资产名称
	Name *string `json:"name,omitempty"`

	// 资产显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集
	Properties *[]PropertyResponse `json:"properties,omitempty"`

	// 分析任务集
	Analyses *[]AnalysisResponse `json:"analyses,omitempty"`

	// 根资产ID
	Root *string `json:"root,omitempty"`

	// 父资产ID，根资产的父资产ID为null
	Parent *string `json:"parent,omitempty"`

	// 子资产ID集
	Children *[]string `json:"children,omitempty"`

	// 资产状态，正常状态（ACTIVE），异常状态（INACTIVE）；只有草稿态（SKETCH）资产有此状态；资产处于异常状态的场景有：1、该资产存在未填写设备ID的测量数据类别的属性；2、该资产存在未填写静态值的静态配置类别的属性；3、该资产存在分析任务，该分析任务的输入参数存在属性引用类型为引用其他资产属性，且没有为该输入参数配置引用的其他资产的资产ID
	State *string `json:"state,omitempty"`

	// 资产发布状态，发布中（PUBLISHING），发布完成（PUBLISHED）；只能对草稿态（SKETCH）的根资产进行发布，也只有草稿态的根资产有此字段；如果根资产从未发布过则值为null
	PublishState *string `json:"publish_state,omitempty"`

	// 创建时间，格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间，格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 发布时间，只能对草稿态（SKETCH）的根资产进行发布，也只有草稿态的根资产有此字段；如果从未发布过则值为null；格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	PublishedTime  *string `json:"published_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateAssetNewResponse) String 

func (o CreateAssetNewResponse) String() string

type CreateBatchJobRequest 

type CreateBatchJobRequest struct {
	Body *Job `json:"body,omitempty"`
}

Request Object

func (CreateBatchJobRequest) String 

func (o CreateBatchJobRequest) String() string

type CreateBatchJobResponse 

type CreateBatchJobResponse struct {

	// 仅在响应返回。作业ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业名称。只能包含数字、英文字母、中文字母、下划线以及中划线。长度为1~128。
	JobName *string `json:"job_name,omitempty"`

	// 标签。只能包含数字、英文字母、中文字符、下划线、中划线、逗号以及斜杠。长度为0~128。
	Tags *string `json:"tags,omitempty"`

	// 仅在响应返回。创建时间。
	CreatedTime *string `json:"created_time,omitempty"`

	// 仅在响应返回。更新时间。
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 作业类型。目前仅支持SqlJob.
	JobType *string `json:"job_type,omitempty"`

	// 作业查询结果导出到OBS的路径。覆写已存在文件。
	ExportPath *string `json:"export_path,omitempty"`

	// 导出文件时是否合并结果文件。true：合并成一个结果文件；false：不合并结果文件。
	MergeResultFile *bool `json:"merge_result_file,omitempty"`

	SqlJob *SqlJob `json:"sql_job,omitempty"`

	Schedule       *Schedule `json:"schedule,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (CreateBatchJobResponse) String 

func (o CreateBatchJobResponse) String() string

type CreateComputingResourceRequest 

type CreateComputingResourceRequest struct {
	Body *CreateComputingResourceRequestBody `json:"body,omitempty"`
}

Request Object

func (CreateComputingResourceRequest) String 

func (o CreateComputingResourceRequest) String() string

type CreateComputingResourceRequestBody 

type CreateComputingResourceRequestBody struct {

	// 新建的计算资源名称，名称只能包含数字、英文字母和下划线，但不能是纯数字，且不能以下划线开头。
	ComputingResourceName string `json:"computing_resource_name"`

	// 计算资源的类型。默认为sql。
	ComputingResourceType *string `json:"computing_resource_type,omitempty"`

	// 计算资源的描述信息。
	Description *string `json:"description,omitempty"`

	// 与计算资源绑定的最小计算单元个数。设置值当前只支持16，64，256。
	CuCount int32 `json:"cu_count"`

	// 计算资源的收费模式。只能设置为“1”，表示按照CU时收费。
	ChargingMode *int32 `json:"charging_mode,omitempty"`
}

func (CreateComputingResourceRequestBody) String 

func (o CreateComputingResourceRequestBody) String() string

type CreateComputingResourceResponse 

type CreateComputingResourceResponse struct {

	// 新增计算资源ID。
	ComputingResourceId *string `json:"computing_resource_id,omitempty"`

	// 新增计算资源名称。
	ComputingResourceName *string `json:"computing_resource_name,omitempty"`

	// 计算资源的类型。目前支持：sql。如果不指定，默认为sql。
	ComputingResourceType *string `json:"computing_resource_type,omitempty"`

	// 计算资源的描述信息。
	Description *string `json:"description,omitempty"`

	// 与计算资源绑定的最小计算单元个数。设置值当前只支持16，64，256。
	CuCount *int32 `json:"cu_count,omitempty"`

	// 计算资源的收费模式。只能设置为“1”，表示按照CU时收费。
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// 创建计算资源时间。时间格式为ISO日期时间格式yyyy-MM-dd'T'HH:mm:ss'Z'。
	CreatedTime    *string `json:"created_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateComputingResourceResponse) String 

func (o CreateComputingResourceResponse) String() string

type CreateDatasourceReqDto 

type CreateDatasourceReqDto struct {

	// 数据源名称
	Name string `json:"name"`

	// 数据源类型, 包括：IOTDA、API[、OBS、DIS、SMN、FUNCTION_GRAPH、MODEL_ARTS、DCS、KAFKA](tag:IoTA-Cloud-Only)、NODE
	Type string `json:"type"`

	Content *ContentDetailReq `json:"content"`
}

func (CreateDatasourceReqDto) String 

func (o CreateDatasourceReqDto) String() string

type CreateDatasourceRequest 

type CreateDatasourceRequest struct {
	Body *CreateDatasourceReqDto `json:"body,omitempty"`
}

Request Object

func (CreateDatasourceRequest) String 

func (o CreateDatasourceRequest) String() string

type CreateDatasourceResponse 

type CreateDatasourceResponse struct {

	// 数据源id
	Id *string `json:"id,omitempty"`

	// 数据源名称
	Name *string `json:"name,omitempty"`

	// 数据源类型, 包括：IOTDA、API[、OBS、DIS、SMN、FUNCTION_GRAPH、MODEL_ARTS、DCS、KAFKA](tag:IoTA-Cloud-Only)、NODE。数据源不支持修改类型。
	Type *string `json:"type,omitempty"`

	Content *ContentDetailRsp `json:"content,omitempty"`

	// 创建时间，格式为：yyyy-MM-dd'T'HH:mm:ss'Z'
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间，格式为：yyyy-MM-dd'T'HH:mm:ss'Z'
	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateDatasourceResponse) String 

func (o CreateDatasourceResponse) String() string

type CreateGroupRequest 

type CreateGroupRequest struct {
	Body *StorageGroup `json:"body,omitempty"`
}

Request Object

func (CreateGroupRequest) String 

func (o CreateGroupRequest) String() string

type CreateGroupResponse 

type CreateGroupResponse struct {

	// 存储组 ID
	GroupId *string `json:"group_id,omitempty"`

	// 存储组名称
	Name *string `json:"name,omitempty"`

	// 描述
	Description *string `json:"description,omitempty"`

	// 温数据存储用量
	WarmDataUsage *int64 `json:"warm_data_usage,omitempty"`

	// 此存储组下存储实例的个数
	DataStoreCount *int64 `json:"data_store_count,omitempty"`

	// 冷数据存储用量
	ColdDataUsage *int64 `json:"cold_data_usage,omitempty"`

	// 温数据老化策略，单位只支持d（天），且只支持整数，如365天则可配置为“365d”，如“365h”或“360.5d”等均不被支持
	WarmDataRetentionPolicy *string `json:"warm_data_retention_policy,omitempty"`

	// 冷数据老化策略，单位只支持d（天），且只支持整数，如365天则可配置为“365d”，如“365h”或“360.5d”等均不被支持
	ColdDataRetentionPolicy *string `json:"cold_data_retention_policy,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 存储类型，有资产存储(取值:AssetStorage)、设备存储(取值:DeviceStorage)两种类型
	Type           *string `json:"type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateGroupResponse) String 

func (o CreateGroupResponse) String() string

type CreateRunRequest 

type CreateRunRequest struct {

	// 作业ID。
	JobId string `json:"job_id"`

	Body *CreateRunRequestBody `json:"body,omitempty"`
}

Request Object

func (CreateRunRequest) String 

func (o CreateRunRequest) String() string

type CreateRunRequestBody 

type CreateRunRequestBody struct {

	// 计算资源ID。
	ComputingResourceId string `json:"computing_resource_id"`

	// 作业配置项。
	Conf *[]string `json:"conf,omitempty"`
}

func (CreateRunRequestBody) String 

func (o CreateRunRequestBody) String() string

type CreateRunResponse 

type CreateRunResponse struct {

	// 作业运行ID。
	RunId *string `json:"run_id,omitempty"`

	// 作业ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业类型。
	JobType *string `json:"job_type,omitempty"`

	// 创建运行时间。
	CreatedTime *string `json:"created_time,omitempty"`

	SqlJob         *SqlJobRunResponseBody `json:"sql_job,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (CreateRunResponse) String 

func (o CreateRunResponse) String() string

type CreateStreamingJobRequest 

type CreateStreamingJobRequest struct {

	// 是否需要校验配置是否正确
	Check *bool `json:"check,omitempty"`

	// 实时分析作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：实时分析算子配置指南。
	Body map[string]interface{} `json:"body,omitempty"`
}

Request Object

func (CreateStreamingJobRequest) String 

func (o CreateStreamingJobRequest) String() string

type CreateStreamingJobResponse 

type CreateStreamingJobResponse struct {

	// 作业ID
	JobId *string `json:"job_id,omitempty"`

	// 作业错误详情
	CheckInfo      map[string]interface{} `json:"check_info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (CreateStreamingJobResponse) String 

func (o CreateStreamingJobResponse) String() string

type CreateTableRequest 

type CreateTableRequest struct {
	Body *CreateTableRequestBody `json:"body,omitempty"`
}

Request Object

func (CreateTableRequest) String 

func (o CreateTableRequest) String() string

type CreateTableRequestBody 

type CreateTableRequestBody struct {

	// 标签。只能包含数字、英文字母、中文字符、下划线、中划线、逗号以及斜杠。长度为0~128。
	Tags *string `json:"tags,omitempty"`

	// 新增表名称。
	TableName string `json:"table_name"`

	// 新增表别名。只能包含数字、英文字母、中文字符、下划线以及中划线。长度为0~32。
	TableAlias *string `json:"table_alias,omitempty"`

	// 新增表的描述信息。
	Description *string `json:"description,omitempty"`

	// 新增表的描述信息。
	Columns []Column `json:"columns"`

	// 新增表的数据类型，目前支持：Parquet、CSV格式。
	DataType string `json:"data_type"`

	// 数据来源。来源类型有：pipeline, default. 默认为default.
	DataSource *string `json:"data_source,omitempty"`

	// 仅当数据来源为pipeline时使用。数据的Data Store ID.
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 表数据是否包含表头。只有CSV类型数据具有该属性。
	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	// 用户自定义数据分隔符。只有CSV类型数据具有该属性。
	Delimiter *string `json:"delimiter,omitempty"`

	// 用户自定义引用字符，默认为双引号（即“\"”）。只有CSV类型数据具有该属性。
	QuoteChar *string `json:"quote_char,omitempty"`

	// 用户自定义转义字符，默认为反斜杠（即\\）。只有CSV类型数据具有该属性。
	EscapeChar *string `json:"escape_char,omitempty"`

	// 用户自定义日期类型，默认格式为“yyyy-MM-dd”。日期格式字符定义详见表3。只有CSV和JSON类型数据具有该属性。
	DateFormat *string `json:"date_format,omitempty"`

	// 用户自定义时间类型。默认格式为“yyyy-MM-dd HH:mm:ss”。时间戳格式字符定义详见表3。只有CSV和JSON类型数据具有该属性。
	TimestampFormat *string `json:"timestamp_format,omitempty"`
}

func (CreateTableRequestBody) String 

func (o CreateTableRequestBody) String() string

type CreateTableResponse 

type CreateTableResponse struct {

	// 表ID。
	TableId *string `json:"table_id,omitempty"`

	// 表名称。
	TableName *string `json:"table_name,omitempty"`

	// 表别名。
	TableAlias *string `json:"table_alias,omitempty"`

	// 表创建时间。
	CreatedTime *string `json:"created_time,omitempty"`

	// 表更新时间。
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 数据存储位置，分为IoTA和VIEW
	DataLocation *string `json:"data_location,omitempty"`

	// 数据类型，包括“csv”，“parquet”。
	DataType *string `json:"data_type,omitempty"`

	// 数据来源。来源类型有：pipeline, default. 默认为default.
	DataSource *string `json:"data_source,omitempty"`

	// 表类型:IoTA表为MANAGED, View为VIEW
	TableType *string `json:"table_type,omitempty"`

	// 表的描述信息。
	Description *string `json:"description,omitempty"`

	// 分区字段。只有OBS分区表有该参数，其他表没有该参数。
	PartitionColumns *[]string `json:"partition_columns,omitempty"`

	// 仅当数据来源为pipeline时返回。Data Store ID.
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 标签。
	Tags           *string `json:"tags,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateTableResponse) String 

func (o CreateTableResponse) String() string

type DataSchema 

type DataSchema struct {

	// integer或double类型的的最小值，当属性值超过范围时系统不予存储，integer时范围：-9223372036854775808 ~ 9223372036854775807；double时范围：-1.7976931348623157E308 ~ 1.7976931348623157E308
	Min float32 `json:"min,omitempty"`

	// integer或double类型的最大值，当属性值超过范围时系统不予存储，integer时范围：-9223372036854775808 ~ 9223372036854775807；double时范围：-1.7976931348623157E308 ~ 1.7976931348623157E308
	Max float32 `json:"max,omitempty"`

	// string类型的最小长度，当属性值超过范围时系统不予存储，范围：0 ~ 4096
	MinLength *int32 `json:"min_length,omitempty"`

	// string类型的最大长度，当属性值超过范围时系统不予存储，范围：0 ~ 4096
	MaxLength *int32 `json:"max_length,omitempty"`

	// 数据类型，字符串（string）、整数（integer）、浮点数（double）、对象（object），系统支持的对象型存储大小为1MB，超过时不予存储
	DataType string `json:"data_type"`
}

数据格式

func (DataSchema) String 

func (o DataSchema) String() string

type DataStoreDto 

type DataStoreDto struct {

	// 存储ID
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 存储组ID
	DataStoreGroupId *string `json:"data_store_group_id,omitempty"`

	// 产品ID
	ProductId *string `json:"product_id,omitempty"`
}

存储信息

func (DataStoreDto) String 

func (o DataStoreDto) String() string

type DatasourceRestDto 

type DatasourceRestDto struct {

	// 数据源id
	Id *string `json:"id,omitempty"`

	// 数据源名称
	Name *string `json:"name,omitempty"`

	// 数据源类型, 包括：IOTDA、API[、OBS、DIS、SMN、FUNCTION_GRAPH、MODEL_ARTS、DCS、KAFKA](tag:IoTA-Cloud-Only)、NODE。数据源不支持修改类型。
	Type *string `json:"type,omitempty"`

	Content *ContentDetailRsp `json:"content,omitempty"`

	// 创建时间，格式为：yyyy-MM-dd'T'HH:mm:ss'Z'
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间，格式为：yyyy-MM-dd'T'HH:mm:ss'Z'
	ModifiedTime *string `json:"modified_time,omitempty"`
}

func (DatasourceRestDto) String 

func (o DatasourceRestDto) String() string

type DcsContentReq 

type DcsContentReq struct {

	// VPC-EP服务端id
	EndpointServiceId string `json:"endpoint_service_id"`

	// VPC-EP服务端名称
	EndpointServiceName string `json:"endpoint_service_name"`

	// VPC-EP客户端Port
	Port int32 `json:"port"`

	// redis实例类型
	DcsType string `json:"dcs_type"`

	// redis访问密码
	Password string `json:"password"`
}

DCS数据源配置内容

func (DcsContentReq) String 

func (o DcsContentReq) String() string

type DcsContentRsp 

type DcsContentRsp struct {

	// VPC-EP服务端id
	EndpointServiceId *string `json:"endpointServiceId,omitempty"`

	// VPC-EP服务端名称
	EndpointServiceName *string `json:"endpointServiceName,omitempty"`

	// VPC-EP客户端IP
	EndpointIp *string `json:"endpointIp,omitempty"`

	// VPC-EP客户端Port
	Port *int32 `json:"port,omitempty"`

	// redis实例类型
	DcsType *string `json:"dcsType,omitempty"`

	// redis访问密码
	Password *string `json:"password,omitempty"`
}

redis数据源配置内容

func (DcsContentRsp) String 

func (o DcsContentRsp) String() string

type DeleteAssetModelRequest 

type DeleteAssetModelRequest struct {

	// 模型ID
	ModelId string `json:"model_id"`
}

Request Object

func (DeleteAssetModelRequest) String 

func (o DeleteAssetModelRequest) String() string

type DeleteAssetModelResponse 

type DeleteAssetModelResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteAssetModelResponse) String 

func (o DeleteAssetModelResponse) String() string

type DeleteAssetNewRequest 

type DeleteAssetNewRequest struct {

	// 资产ID
	AssetId string `json:"asset_id"`
}

Request Object

func (DeleteAssetNewRequest) String 

func (o DeleteAssetNewRequest) String() string

type DeleteAssetNewResponse 

type DeleteAssetNewResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteAssetNewResponse) String 

func (o DeleteAssetNewResponse) String() string

type DeleteBatchJobRequest 

type DeleteBatchJobRequest struct {

	// 数据开发任务ID。
	JobId string `json:"job_id"`
}

Request Object

func (DeleteBatchJobRequest) String 

func (o DeleteBatchJobRequest) String() string

type DeleteBatchJobResponse 

type DeleteBatchJobResponse struct {

	// 被删除作业ID。
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteBatchJobResponse) String 

func (o DeleteBatchJobResponse) String() string

type DeleteComputingResourceRequest 

type DeleteComputingResourceRequest struct {

	// 计算资源ID。
	ComputingResourceId string `json:"computing_resource_id"`
}

Request Object

func (DeleteComputingResourceRequest) String 

func (o DeleteComputingResourceRequest) String() string

type DeleteComputingResourceResponse 

type DeleteComputingResourceResponse struct {

	// 被删除计算资源ID。
	ComputingResourceId *string `json:"computing_resource_id,omitempty"`
	HttpStatusCode      int     `json:"-"`
}

Response Object

func (DeleteComputingResourceResponse) String 

func (o DeleteComputingResourceResponse) String() string

type DeleteDataStoreRequest 

type DeleteDataStoreRequest struct {

	// 存储 ID
	DataStoreId string `json:"data_store_id"`
}

Request Object

func (DeleteDataStoreRequest) String 

func (o DeleteDataStoreRequest) String() string

type DeleteDataStoreResponse 

type DeleteDataStoreResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteDataStoreResponse) String 

func (o DeleteDataStoreResponse) String() string

type DeleteDatasourceRequest 

type DeleteDatasourceRequest struct {

	// 数据源id
	DatasourceId string `json:"datasource_id"`
}

Request Object

func (DeleteDatasourceRequest) String 

func (o DeleteDatasourceRequest) String() string

type DeleteDatasourceResponse 

type DeleteDatasourceResponse struct {

	// 删除数据源的id
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteDatasourceResponse) String 

func (o DeleteDatasourceResponse) String() string

type DeleteGroupRequest 

type DeleteGroupRequest struct {

	// 存储组 ID
	GroupId string `json:"group_id"`
}

Request Object

func (DeleteGroupRequest) String 

func (o DeleteGroupRequest) String() string

type DeleteGroupResponse 

type DeleteGroupResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteGroupResponse) String 

func (o DeleteGroupResponse) String() string

type DeletePipelineJobRequest 

type DeletePipelineJobRequest struct {

	// 管道ID
	PipelineId string `json:"pipeline_id"`
}

Request Object

func (DeletePipelineJobRequest) String 

func (o DeletePipelineJobRequest) String() string

type DeletePipelineJobResponse 

type DeletePipelineJobResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeletePipelineJobResponse) String 

func (o DeletePipelineJobResponse) String() string

type DeleteRunRequest 

type DeleteRunRequest struct {

	// 作业ID。
	JobId string `json:"job_id"`

	// 作业运行ID。
	RunId string `json:"run_id"`
}

Request Object

func (DeleteRunRequest) String 

func (o DeleteRunRequest) String() string

type DeleteRunResponse 

type DeleteRunResponse struct {

	// 被取消作业运行ID
	RunId          *string `json:"run_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteRunResponse) String 

func (o DeleteRunResponse) String() string

type DeleteStreamingJobByIdRequest 

type DeleteStreamingJobByIdRequest struct {

	// 作业ID
	JobId string `json:"job_id"`
}

Request Object

func (DeleteStreamingJobByIdRequest) String 

func (o DeleteStreamingJobByIdRequest) String() string

type DeleteStreamingJobByIdResponse 

type DeleteStreamingJobByIdResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteStreamingJobByIdResponse) String 

func (o DeleteStreamingJobByIdResponse) String() string

type DeleteTableRequest 

type DeleteTableRequest struct {

	// 表ID
	TableId string `json:"table_id"`
}

Request Object

func (DeleteTableRequest) String 

func (o DeleteTableRequest) String() string

type DeleteTableResponse 

type DeleteTableResponse struct {

	// 被删除表ID
	TableId *string `json:"table_id,omitempty"`

	// 被删除表名。
	TableName      *string `json:"table_name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteTableResponse) String 

func (o DeleteTableResponse) String() string

type DisContentReq 

type DisContentReq struct {

	// 项目id
	ProjectId string `json:"project_id"`

	// 通道名称
	StreamName string `json:"stream_name"`

	// 租户的AK
	Ak string `json:"ak"`

	// 租户的SK
	Sk string `json:"sk"`
}

DIS数据源配置内容

func (DisContentReq) String 

func (o DisContentReq) String() string

type DisContentRsp 

type DisContentRsp struct {

	// 通道名称
	StreamName *string `json:"streamName,omitempty"`

	// 租户的AK
	Ak *string `json:"ak,omitempty"`

	// 租户的SK
	Sk *string `json:"sk,omitempty"`

	// 项目id
	ProjectId *string `json:"projectId,omitempty"`
}

DIS数据源配置内容

func (DisContentRsp) String 

func (o DisContentRsp) String() string

type DtAggregateMetrics 

type DtAggregateMetrics struct {

	// 定义指标计算查询的输入资产属性列表
	Inputs []MetricInput `json:"inputs"`

	// 指标表达式,最多64个字符
	Expression string `json:"expression"`

	// 指标名，指标计算查询的输出指标名称
	MetricName string `json:"metric_name"`
}

聚合指标列表

func (DtAggregateMetrics) String 

func (o DtAggregateMetrics) String() string

type DtAggregateRequest 

type DtAggregateRequest struct {

	// 输入参数，最多支持10个
	Inputs *[]InputRequest `json:"inputs,omitempty"`

	Outputs *[]OutputRequest `json:"outputs,omitempty"`
}

聚合计算

func (DtAggregateRequest) String 

func (o DtAggregateRequest) String() string

type DtSchedule 

type DtSchedule struct {

	// 调度周期，正则： \"1m|5m|15m|1h\"，表示从每小时第0分0秒开始，每1m、5m、15m、1h调度
	Period string `json:"period"`
}

调度策略

func (DtSchedule) String 

func (o DtSchedule) String() string

type DtStreamRequest 

type DtStreamRequest struct {

	// 输入参数，最多支持10个
	Inputs []InputRequest `json:"inputs"`
}

流计算

func (DtStreamRequest) String 

func (o DtStreamRequest) String() string

type DtTransformMetrics 

type DtTransformMetrics struct {

	// 定义指标计算查询的输入资产属性列表
	Inputs []MetricInput `json:"inputs"`

	// 指标表达式,最多64个字符
	Expression string `json:"expression"`

	// 指标名，指标计算查询的输出指标名称
	MetricName string `json:"metric_name"`
}

转换指标列表

func (DtTransformMetrics) String 

func (o DtTransformMetrics) String() string

type DtTransformRequest 

type DtTransformRequest struct {

	// 输入参数，最多支持10个
	Inputs *[]InputRequest `json:"inputs,omitempty"`

	Outputs *[]OutputRequest `json:"outputs,omitempty"`
}

转换计算

func (DtTransformRequest) String 

func (o DtTransformRequest) String() string

type EdgeContentReq 

type EdgeContentReq struct {

	// edge实例Id
	IotdaInstanceId *string `json:"iotda_instance_id,omitempty"`

	// 在edge实例中要配置转发规则推送数据的资源空间和产品列表
	Rules []EdgeContentRuleReq `json:"rules"`
}

IoTDA数据源详细配置内容

func (EdgeContentReq) String 

func (o EdgeContentReq) String() string

type EdgeContentRsp 

type EdgeContentRsp struct {

	// Edge实例Id
	IotdaInstanceId string `json:"iotda_instance_id"`

	// 在Edge实例中要配置的转发规则，包含推送数据的资源空间和产品列表
	Rules []EdgeContentRuleRsp `json:"rules"`
}

IoTDA数据源详细配置内容

func (EdgeContentRsp) String 

func (o EdgeContentRsp) String() string

type EdgeContentRuleReq 

type EdgeContentRuleReq struct {

	// Edge中的资源空间Id
	AppId string `json:"app_id"`

	// Edge中某资源空间Id下的产品列表
	Products []string `json:"products"`
}

在Edge实例中要配置转发规则推送数据的资源空间和产品列表

func (EdgeContentRuleReq) String 

func (o EdgeContentRuleReq) String() string

type EdgeContentRuleRsp 

type EdgeContentRuleRsp struct {

	// Edge中的资源空间Id
	AppId string `json:"app_id"`

	// Edge中某资源空间Id下的产品列表
	Products []string `json:"products"`

	// Edge中rule_id和action_id列表
	RuleActions []IotdaRuleAction `json:"rule_actions"`
}

在Edge实例中要配置转发规则推送数据的资源空间和产品列表

func (EdgeContentRuleRsp) String 

func (o EdgeContentRuleRsp) String() string

type ExportDatasetRequest 

type ExportDatasetRequest struct {

	// 作业ID。
	JobId string `json:"job_id"`

	// 作业运行ID。
	RunId string `json:"run_id"`
}

Request Object

func (ExportDatasetRequest) String 

func (o ExportDatasetRequest) String() string

type ExportDatasetResponse 

type ExportDatasetResponse struct {
	HttpStatusCode int           `json:"-"`
	Body           io.ReadCloser `json:"-" type:"stream"`
}

Response Object

func (ExportDatasetResponse) Consume 

func (o ExportDatasetResponse) Consume(writer io.Writer) (int64, error)

func (ExportDatasetResponse) String 

func (o ExportDatasetResponse) String() string

type Expression 

type Expression struct {

	// 公式，最多1024个字符(分析任务单输出场景，配合TransformModel或AggregateModel的output_property使用)
	Formula *string `json:"formula,omitempty"`

	// 带名称的公式
	Formulas *[]NamedFormula `json:"formulas,omitempty"`

	// 时间范围，调度时间往前的时间范围，比如1m表示调度时间往前1分钟到调度时间的时间范围，正则：\"1m|5m|15m|1h\"
	TimeRange string `json:"time_range"`
}

表达式

func (Expression) String 

func (o Expression) String() string

type Formula 

type Formula struct {

	// 公式，最多1024个字符(分析任务单输出场景，配合TransformModel或AggregateModel的output_property使用)
	Formula *string `json:"formula,omitempty"`

	// 带名称的公式
	Formulas *[]NamedFormula `json:"formulas,omitempty"`
}

表达式

func (Formula) String 

func (o Formula) String() string

type FunctionGraphContentReq 

type FunctionGraphContentReq struct {

	// 名称
	FunctionName string `json:"function_name"`

	// 原始URL
	OrigUrl string `json:"orig_url"`

	// 转换后的URL
	FinalUrl string `json:"final_url"`

	// 校验参数
	VerifyBody string `json:"verify_body"`

	// 租户的AK
	Ak string `json:"ak"`

	// 租户的SK
	Sk string `json:"sk"`

	// 项目id
	ProjectId string `json:"project_id"`
}

FunctionGraph数据源配置内容

func (FunctionGraphContentReq) String 

func (o FunctionGraphContentReq) String() string

type FunctionGraphContentRsp 

type FunctionGraphContentRsp struct {

	// 名称
	FunctionName *string `json:"functionName,omitempty"`

	// 原始URL
	OrigUrl *string `json:"origUrl,omitempty"`

	// 转换后的URL
	FinalUrl *string `json:"finalUrl,omitempty"`

	// 校验参数
	VerifyBody *string `json:"verifyBody,omitempty"`

	// 租户的AK
	Ak *string `json:"ak,omitempty"`

	// 租户的SK
	Sk *string `json:"sk,omitempty"`

	// 项目id
	ProjectId *string `json:"projectId,omitempty"`
}

SMN数据源配置内容

func (FunctionGraphContentRsp) String 

func (o FunctionGraphContentRsp) String() string

type GetDataStore 

type GetDataStore struct {

	// 存储 ID
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 存储名称
	Name *string `json:"name,omitempty"`

	// 存储 ID
	GroupId *string `json:"group_id,omitempty"`

	// 标签
	Tags *[]Tag `json:"tags,omitempty"`

	// 指标
	Metrics *[]Metric `json:"metrics,omitempty"`

	// 属性
	Properties *[]Property `json:"properties,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	ModifiedTime *string `json:"modified_time,omitempty"`
}

func (GetDataStore) String 

func (o GetDataStore) String() string

type GetGroup 

type GetGroup struct {

	// 存储组 ID
	GroupId *string `json:"group_id,omitempty"`

	// 存储组名称
	Name *string `json:"name,omitempty"`

	// 描述
	Description *string `json:"description,omitempty"`

	// 温数据存储用量
	WarmDataUsage *int64 `json:"warm_data_usage,omitempty"`

	// 此存储组下存储实例的个数
	DataStoreCount *int64 `json:"data_store_count,omitempty"`

	// 冷数据存储用量
	ColdDataUsage *int64 `json:"cold_data_usage,omitempty"`

	// 温数据老化策略，单位只支持d（天），且只支持整数，如365天则可配置为“365d”，如“365h”或“360.5d”等均不被支持
	WarmDataRetentionPolicy *string `json:"warm_data_retention_policy,omitempty"`

	// 冷数据老化策略，单位只支持d（天），且只支持整数，如365天则可配置为“365d”，如“365h”或“360.5d”等均不被支持
	ColdDataRetentionPolicy *string `json:"cold_data_retention_policy,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 存储类型，有资产存储(取值:AssetStorage)、设备存储(取值:DeviceStorage)两种类型
	Type *string `json:"type,omitempty"`
}

存储组信息

func (GetGroup) String 

func (o GetGroup) String() string

type GetHistoryRequest 

type GetHistoryRequest struct {
	TimeSpan *TimeSpan `json:"time_span"`

	// 对property按指定tags标签进行过滤查询，填入设备标签与标签值，不可为空，例如 {\"deviceId\": \"id0001\"}
	Tags map[string]string `json:"tags"`

	// 查询的属性列表
	PropertyNames []string `json:"property_names"`

	// 返回值个数限制
	Limit *int32 `json:"limit,omitempty"`
}

查询历史值请求

func (GetHistoryRequest) String 

func (o GetHistoryRequest) String() string

type GetMetricsRequest 

type GetMetricsRequest struct {

	// 查询类型
	Type string `json:"type"`

	Transform *TransformMetrics `json:"transform,omitempty"`

	Aggregate *AggregateMetrics `json:"aggregate,omitempty"`
}

查询指标请求

func (GetMetricsRequest) String 

func (o GetMetricsRequest) String() string

type GetMetricsValue 

type GetMetricsValue struct {

	// 查询类型，经过转换计算的序列值（transform）、经过聚合计算的序列值（aggregate）
	Type string `json:"type"`

	Transform *TransformMetricsRequest `json:"transform,omitempty"`

	Aggregate *AggregateMetricsRequest `json:"aggregate,omitempty"`
}

func (GetMetricsValue) String 

func (o GetMetricsValue) String() string

type GetPropertyRequest 

type GetPropertyRequest struct {

	// 对property按指定tags标签进行过滤查询，填入设备标签与标签值，不可为空，例如 {\"deviceId\": \"id0001\"}
	Tags map[string]string `json:"tags"`

	// 查询设备的属性名称
	PropertyNames *[]string `json:"property_names,omitempty"`
}

查询属性值请求

func (GetPropertyRequest) String 

func (o GetPropertyRequest) String() string

type HistoryValues 

type HistoryValues struct {

	// 属性名称
	PropertyName *string `json:"property_name,omitempty"`

	// 属性值
	Values *[]interface{} `json:"values,omitempty"`
}

func (HistoryValues) String 

func (o HistoryValues) String() string

type ImportDataRequest 

type ImportDataRequest struct {
	Body *ImportDataRequestBody `json:"body,omitempty"`
}

Request Object

func (ImportDataRequest) String 

func (o ImportDataRequest) String() string

type ImportDataRequestBody 

type ImportDataRequestBody struct {

	// 导入的数据路径（当前仅支持导入OBS上的数据，且OBS路径须以s3a开头）。必须先把该OBS桶添加到离线数据源。
	DataPath string `json:"data_path"`

	// 导入的数据类型（当前支持csv、parquet、orc、json、avro数据类型）。
	DataType string `json:"data_type"`

	// 表ID。
	TableId string `json:"table_id"`

	// 导入数据中的第一行数据是否包括列名，即表头。默认为“false”，表示不包括列名。导入CSV类型数据时可指定。
	WithColumnHeader *string `json:"with_column_header,omitempty"`

	// 用户自定义数据分隔符，默认为逗号。导入CSV类型数据时可指定。
	Delimiter *string `json:"delimiter,omitempty"`

	// 用户自定义引用字符，默认为双引号。导入CSV类型数据时可指定。
	QuoteChar *string `json:"quote_char,omitempty"`

	// 用户自定义转义字符，默认为反斜杠。导入CSV类型数据时可指定。
	EscapeChar *string `json:"escape_char,omitempty"`

	// 指定特定的日期格式，默认为“yyyy-MM-dd”。日期格式字符定义详见表3。导入CSV及JSON类型数据时可指定。
	DateFormat *string `json:"date_format,omitempty"`

	// 作业执行过程中的bad records存储目录。设置该配置项后，bad records不会导入到目标表。
	BadRecordsPath *string `json:"bad_records_path,omitempty"`

	// 指定特定的时间格式，默认为“yyyy-MM-dd HH:mm:ss”。时间格式字符定义详见表3。导入CSV及JSON类型数据时可指定。
	TimestampFormat *string `json:"timestamp_format,omitempty"`

	// 计算资源ID。
	ComputingResourceId string `json:"computing_resource_id"`
}

func (ImportDataRequestBody) String 

func (o ImportDataRequestBody) String() string

type ImportDataResponse 

type ImportDataResponse struct {

	// 表ID。
	TableId *string `json:"table_id,omitempty"`

	// 作业ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业运行ID。
	RunId          *string `json:"run_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ImportDataResponse) String 

func (o ImportDataResponse) String() string

type InputModel 

type InputModel struct {

	// 参数名称，正则：\"^[A-Za-z][A-Za-z_]{0,31}$\"
	Name string `json:"name"`

	PropertyReference *PropertyReferenceModel `json:"property_reference"`
}

func (InputModel) String 

func (o InputModel) String() string

type InputParam 

type InputParam struct {

	// 参数名称
	Name string `json:"name"`

	// 属性名称
	PropertyName string `json:"property_name"`
}

属性定义为输入参数

func (InputParam) String 

func (o InputParam) String() string

type InputRequest 

type InputRequest struct {

	// 参数名，正则： \"^[A-Za-z][A-Za-z_]{0,31}$\"
	Name string `json:"name"`

	PropertyReference *PropertyReferenceReq `json:"property_reference"`
}

func (InputRequest) String 

func (o InputRequest) String() string

type InputResponse 

type InputResponse struct {

	// 参数名
	Name *string `json:"name,omitempty"`

	PropertyReference *PropertyReferenceResponse `json:"property_reference,omitempty"`
}

func (InputResponse) String 

func (o InputResponse) String() string

type IotdaContentReq 

type IotdaContentReq struct {

	// IoTDA实例Id
	IotdaInstanceId string `json:"iotda_instance_id"`

	// 在IoTDA实例中要配置转发规则推送数据的资源空间和产品列表
	Rules []IotdaContentRuleReq `json:"rules"`
}

IoTDA数据源详细配置内容

func (IotdaContentReq) String 

func (o IotdaContentReq) String() string

type IotdaContentRsp 

type IotdaContentRsp struct {

	// IoTDA实例Id
	IotdaInstanceId string `json:"iotda_instance_id"`

	// 在IoTDA实例中要配置的转发规则，包含推送数据的资源空间和产品列表
	Rules []IotdaContentRuleRsp `json:"rules"`
}

IoTDA数据源详细配置内容

func (IotdaContentRsp) String 

func (o IotdaContentRsp) String() string

type IotdaContentRuleReq 

type IotdaContentRuleReq struct {

	// IoTDA中的资源空间Id
	AppId string `json:"app_id"`

	// IoTDA中某资源空间Id下的产品列表
	Products []string `json:"products"`
}

在IoTDA实例中要配置转发规则推送数据的资源空间和产品列表

func (IotdaContentRuleReq) String 

func (o IotdaContentRuleReq) String() string

type IotdaContentRuleRsp 

type IotdaContentRuleRsp struct {

	// IoTDA中的资源空间Id
	AppId string `json:"app_id"`

	// IoTDA中某资源空间Id下的产品列表
	Products []string `json:"products"`

	// IoTDA中rule_id和action_id列表
	RuleActions []IotdaRuleAction `json:"rule_actions"`
}

在IoTDA实例中要配置转发规则推送数据的资源空间和产品列表

func (IotdaContentRuleRsp) String 

func (o IotdaContentRuleRsp) String() string

type IotdaRuleAction 

type IotdaRuleAction struct {

	// IoTDA中的规则Id
	RuleId string `json:"rule_id"`

	// IoTDA中推送数据动作ID
	ActionId string `json:"action_id"`
}

在IoTDA实例中的规则ID及其配套的推送数据动作ID

func (IotdaRuleAction) String 

func (o IotdaRuleAction) String() string

type Job 

type Job struct {

	// 仅在响应返回。作业ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业名称。只能包含数字、英文字母、中文字母、下划线以及中划线。长度为1~128。
	JobName string `json:"job_name"`

	// 标签。只能包含数字、英文字母、中文字符、下划线、中划线、逗号以及斜杠。长度为0~128。
	Tags *string `json:"tags,omitempty"`

	// 仅在响应返回。创建时间。
	CreatedTime *string `json:"created_time,omitempty"`

	// 仅在响应返回。更新时间。
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 作业类型。目前仅支持SqlJob.
	JobType string `json:"job_type"`

	// 作业查询结果导出到OBS的路径。覆写已存在文件。
	ExportPath *string `json:"export_path,omitempty"`

	// 导出文件时是否合并结果文件。true：合并成一个结果文件；false：不合并结果文件。
	MergeResultFile *bool `json:"merge_result_file,omitempty"`

	SqlJob *SqlJob `json:"sql_job,omitempty"`

	Schedule *Schedule `json:"schedule,omitempty"`
}

作业。

func (Job) String 

func (o Job) String() string

type KafkaAuthInfo 

type KafkaAuthInfo struct {

	// 安全协议
	SecurityProtocol string `json:"security_protocol"`

	SaslPlainAuthInfo *SaslPlainAuthInfo `json:"sasl_plain_auth_info,omitempty"`
}

Kafka 认证信息

func (KafkaAuthInfo) String 

func (o KafkaAuthInfo) String() string

type KafkaBrokerInfo 

type KafkaBrokerInfo struct {

	// IP
	Ip string `json:"ip"`

	// Port
	Port int32 `json:"port"`
}

Kafka Server地址

func (KafkaBrokerInfo) String 

func (o KafkaBrokerInfo) String() string

type KafkaContentReq 

type KafkaContentReq struct {

	// KAFKA连接方式
	ConnectionType string `json:"connection_type"`

	// Kafka实例ID
	InstanceId *string `json:"instance_id,omitempty"`

	// Kafka的VPCEP信息包括service_id,service_name,client_port
	VpcepInfos *[]VpcepInfo `json:"vpcep_infos,omitempty"`

	// Kafka的broker信息包括broker_ip, broker_port
	BrokerInfos *[]KafkaBrokerInfo `json:"broker_infos,omitempty"`

	AuthInfo *KafkaAuthInfo `json:"auth_info,omitempty"`
}

Kafka数据源请求内容

func (KafkaContentReq) String 

func (o KafkaContentReq) String() string

type KafkaContentRsp 

type KafkaContentRsp struct {

	// KAFKA连接类型
	ConnectionType *string `json:"connection_type,omitempty"`

	// Kafka实例ID
	InstanceId *string `json:"instance_id,omitempty"`

	// Kafka的VPCEP信息包括service_id,service_name,client_port
	VpcepInfos *[]VpcepInfoRsp `json:"vpcep_infos,omitempty"`

	// Kafka的broker信息包括broker_ip, broker_port
	BrokerInfos *[]KafkaBrokerInfo `json:"broker_infos,omitempty"`

	AuthInfo *KafkaAuthInfo `json:"auth_info,omitempty"`
}

Kafka数据源请求内容

func (KafkaContentRsp) String 

func (o KafkaContentRsp) String() string

type KeyValue 

type KeyValue struct {

	// 键。
	Key *string `json:"key,omitempty"`

	// 值。
	Value *string `json:"value,omitempty"`
}

func (KeyValue) String 

func (o KeyValue) String() string

type LastAssetPropertyValueRequest 

type LastAssetPropertyValueRequest struct {

	// 对property按指定tags标签进行过滤查询，填入资产标签属性的属性名与属性值，不可为空，例如 {\"tagPropertyA\": \"id0001\"}；注意，标签过滤只对打上标签时刻之后的数据生效，打标签之前的数据不能通过标签过滤
	Tags map[string]interface{} `json:"tags,omitempty"`

	// 属性过滤器，最多5个
	PropertyFilter *[]PropertyFilter `json:"property_filter,omitempty"`

	// 待查询的资产属性名列表,不携带该字段表示查询全部
	PropertyNames *[]string `json:"property_names,omitempty"`
}

查询资产属性最新值请求

func (LastAssetPropertyValueRequest) String 

func (o LastAssetPropertyValueRequest) String() string

type ListAssetModelsRequest 

type ListAssetModelsRequest struct {

	// 过滤条件 示例： {\"key\":\"xxx\"} {\"key1\":\"xxx\",\"key2\":\"xxx\"} {\"key\":{\"eq|like\":\"xxx\"}} {\"key\":{\"in\":[\"xxx\",\"xxx\"]}} {\"or\":{\"key1\":\"xxx\",\"key2\":{\"eq|like\":\"xxx\"},\"key3\":{\"in\":[\"xxx\",\"xxx\"]}}} {\"and\":{\"key1\":\"xxx\",\"key2\":{\"eq|like\":\"xxx\"},\"key3\":{\"in\":[\"xxx\",\"xxx\"]}}} 支持的key： asset_model_id，name，display_name，job_id 注意： job_id只支持contain过滤 {\"job_id\":{\"contain\":\"xxx\"}}
	Filter *string `json:"filter,omitempty"`

	// 每页记录数
	Limit *int32 `json:"limit,omitempty"`

	// 页码
	Offset *int32 `json:"offset,omitempty"`
}

Request Object

func (ListAssetModelsRequest) String 

func (o ListAssetModelsRequest) String() string

type ListAssetModelsResponse 

type ListAssetModelsResponse struct {

	// 总数
	Count *int64 `json:"count,omitempty"`

	// 模型集，数量不超过limit
	AssetModels    *[]AssetModelResponse `json:"asset_models,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (ListAssetModelsResponse) String 

func (o ListAssetModelsResponse) String() string

type ListAssetsNewRequest 

type ListAssetsNewRequest struct {

	// 每页记录数
	Limit *int32 `json:"limit,omitempty"`

	// 页码
	Offset *int32 `json:"offset,omitempty"`

	// 查询过滤器 示例： {\"key\":\"xxx\"} {\"key1\":\"xxx\",\"key2\":\"xxx\"} {\"key\":{\"eq|like\":\"xxx\"}} {\"key\":{\"in\":[\"xxx\",\"xxx\"]}} {\"or\":{\"key1\":\"xxx\",\"key2\":{\"eq|like\":\"xxx\"},\"key3\":{\"in\":[\"xxx\",\"xxx\"]}}} {\"and\":{\"key1\":\"xxx\",\"key2\":{\"eq|like\":\"xxx\"},\"key3\":{\"in\":[\"xxx\",\"xxx\"]}}} 支持的key： asset_model_id，asset_id，parent，name，display_name，root，state，job_id 注意： job_id只在RELEASE态下生效，只支持contain过滤 {\"job_id\":{\"contain\":\"xxx\"}}
	Filter *string `json:"filter,omitempty"`

	// SKETCH：草稿态；RELEASE：发布态
	Type string `json:"type"`
}

Request Object

func (ListAssetsNewRequest) String 

func (o ListAssetsNewRequest) String() string

type ListAssetsNewResponse 

type ListAssetsNewResponse struct {

	// 总数
	Count *int64 `json:"count,omitempty"`

	// 资产集，数量不超过limit
	Assets         *[]AssetResponse `json:"assets,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (ListAssetsNewResponse) String 

func (o ListAssetsNewResponse) String() string

type ListBatchJobsRequest 

type ListBatchJobsRequest struct {

	// 当前偏移量，默认为0。
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的最大作业个数，范围: [1, 100]。默认值：10。
	Limit *int32 `json:"limit,omitempty"`

	// 是否定时作业。true：定时作业：false：不是定时作业。为空时：所有作业。
	HasSchedule *bool `json:"has_schedule,omitempty"`

	// 作业名称
	JobName *string `json:"job_name,omitempty"`

	// 调度状态。1:NORMAL, 2:PAUSED, 3:COMPLETE, 4:ERROR, 5:BLOCKED
	ScheduleStatus *string `json:"schedule_status,omitempty"`

	// 指定作业排序字段，默认为created_time（作业创建时间），支持created_time(作业创建时间)、modified_time（作业更新时间） 、job_name（作业名称）三种排序字段。
	OrderBy *string `json:"order_by,omitempty"`

	// 指定作业排序的升降序，默认为desc（降序），支持asc（升序）、desc（降序）两种排序方式。
	Order *string `json:"order,omitempty"`
}

Request Object

func (ListBatchJobsRequest) String 

func (o ListBatchJobsRequest) String() string

type ListBatchJobsResponse 

type ListBatchJobsResponse struct {

	// 定时作业总个数。
	Count *int64 `json:"count,omitempty"`

	Jobs           *[]Job `json:"jobs,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListBatchJobsResponse) String 

func (o ListBatchJobsResponse) String() string

type ListComputingResourcesRequest 

type ListComputingResourcesRequest struct {

	// 计算资源名称。
	ComputingResourceName *string `json:"computing_resource_name,omitempty"`

	// 当前偏移量，默认为0。
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的最大作业个数，范围: [1, 100]。默认值：10。
	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ListComputingResourcesRequest) String 

func (o ListComputingResourcesRequest) String() string

type ListComputingResourcesResponse 

type ListComputingResourcesResponse struct {

	// 计算资源总个数。
	Count *int64 `json:"count,omitempty"`

	// 计算资源列表。
	ComputingResources *[]ComputingResource `json:"computing_resources,omitempty"`
	HttpStatusCode     int                  `json:"-"`
}

Response Object

func (ListComputingResourcesResponse) String 

func (o ListComputingResourcesResponse) String() string

type ListDataStoresRequest 

type ListDataStoresRequest struct {

	// 存储组 ID
	GroupId *string `json:"group_id,omitempty"`

	// 存储 ID
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 存储名称
	Name *string `json:"name,omitempty"`

	// 页码
	Offset *int32 `json:"offset,omitempty"`

	// 返回条数限制
	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ListDataStoresRequest) String 

func (o ListDataStoresRequest) String() string

type ListDataStoresResponse 

type ListDataStoresResponse struct {

	// 数据结构列表
	DataStores *[]GetDataStore `json:"data_stores,omitempty"`

	// 返回的 data-store 数量
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListDataStoresResponse) String 

func (o ListDataStoresResponse) String() string

type ListGroupsRequest 

type ListGroupsRequest struct {

	// 存储用量单位
	Unit *ListGroupsRequestUnit `json:"unit,omitempty"`

	// 存储类型，有资产存储(取值:AssetStorage)、设备存储(取值:DeviceStorage)两种类型
	Type *string `json:"type,omitempty"`

	// 存储组 ID
	GroupId *string `json:"group_id,omitempty"`

	// 存储组名称
	Name *string `json:"name,omitempty"`

	// 页码
	Offset *int32 `json:"offset,omitempty"`

	// 返回条数限制
	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ListGroupsRequest) String 

func (o ListGroupsRequest) String() string

type ListGroupsRequestUnit 

type ListGroupsRequestUnit struct {
	// contains filtered or unexported fields
}

func (ListGroupsRequestUnit) MarshalJSON 

func (c ListGroupsRequestUnit) MarshalJSON() ([]byte, error)

func (*ListGroupsRequestUnit) UnmarshalJSON 

func (c *ListGroupsRequestUnit) UnmarshalJSON(b []byte) error

func (ListGroupsRequestUnit) Value added in v0.0.90 

func (c ListGroupsRequestUnit) Value() string

type ListGroupsRequestUnitEnum 

type ListGroupsRequestUnitEnum struct {
	MB ListGroupsRequestUnit
}

func GetListGroupsRequestUnitEnum 

func GetListGroupsRequestUnitEnum() ListGroupsRequestUnitEnum

type ListGroupsResponse 

type ListGroupsResponse struct {

	// 存储组列表
	Groups *[]GetGroup `json:"groups,omitempty"`

	// 返回的 data-store-group 数量
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListGroupsResponse) String 

func (o ListGroupsResponse) String() string

type ListHistoryRequest 

type ListHistoryRequest struct {

	// 存储ID
	DataStoreId string `json:"data_store_id"`

	Body *GetHistoryRequest `json:"body,omitempty"`
}

Request Object

func (ListHistoryRequest) String 

func (o ListHistoryRequest) String() string

type ListHistoryResponse 

type ListHistoryResponse struct {

	// 时间序列
	Timestamps *[]string `json:"timestamps,omitempty"`

	// 查询设备的属性值
	Properties     *[]HistoryValues `json:"properties,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (ListHistoryResponse) String 

func (o ListHistoryResponse) String() string

type ListMetricsRequest 

type ListMetricsRequest struct {

	// 存储ID
	DataStoreId string `json:"data_store_id"`

	Body *GetMetricsRequest `json:"body,omitempty"`
}

Request Object

func (ListMetricsRequest) String 

func (o ListMetricsRequest) String() string

type ListMetricsResponse 

type ListMetricsResponse struct {

	// 时间序列
	Timestamps *[]string `json:"timestamps,omitempty"`

	// 查询的测量指标列表
	Metrics        *[]MetricList `json:"metrics,omitempty"`
	HttpStatusCode int           `json:"-"`
}

Response Object

func (ListMetricsResponse) String 

func (o ListMetricsResponse) String() string

type ListPipelineJobsRequest 

type ListPipelineJobsRequest struct {

	// 数据存储Id
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 存储组Id
	DataStoreGroupId *string `json:"data_store_group_id,omitempty"`

	// 数据源Id
	DataSourceId *string `json:"data_source_id,omitempty"`

	// 管道名称
	PipelineName *string `json:"pipeline_name,omitempty"`

	// 包含的管道类名
	OperatorClassName *string `json:"operator_class_name,omitempty"`

	// 偏移量，表示从此偏移量开始查询，offset大于等于0
	Offset *int64 `json:"offset,omitempty"`

	// 每页显示的条目数量
	Limit *int32 `json:"limit,omitempty"`

	// 立即同步作业状态，默认是false
	SyncStatus *bool `json:"sync_status,omitempty"`
}

Request Object

func (ListPipelineJobsRequest) String 

func (o ListPipelineJobsRequest) String() string

type ListPipelineJobsResponse 

type ListPipelineJobsResponse struct {

	// 总数
	Count *int64 `json:"count,omitempty"`

	// 管道列表
	Pipelines      *[]PipelineJobInfoDto `json:"pipelines,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (ListPipelineJobsResponse) String 

func (o ListPipelineJobsResponse) String() string

type ListRunsRequest 

type ListRunsRequest struct {

	// 当前偏移量，默认为0。
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的最大作业个数，范围: [1, 100]。默认值：10。
	Limit *int32 `json:"limit,omitempty"`

	// 用于查询开始时间在该时间点之后的作业。时间格式为ISO日期时间格式yyyy-MM-dd'T'HH:mm:ss.SSS。
	StartTime *string `json:"start_time,omitempty"`

	// 用于查询开始时间在该时间点之前的作业。时间格式为ISO日期时间格式yyyy-MM-dd'T'HH:mm:ss.SSS。
	EndTime *string `json:"end_time,omitempty"`

	// 仅当作业类型为SqlJob时可用。指定sql片段作为作业过滤条件，不区分大小写。
	SqlPattern *string `json:"sql_pattern,omitempty"`

	// 仅当作业类型为SqlJob时可用。SQL作业类型。DDL, DCL, IMPORT, EXPORT, QUERY, INSERT, SELECT, DATA_MIGRATION, ANALYZE, OBS_SELECT, COMPLEX
	SqlType *string `json:"sql_type,omitempty"`

	// 作业类型。目前仅支持SqlJob
	JobType *string `json:"job_type,omitempty"`

	// 此作业的当前状态，包含提交（LAUNCHING）、运行中（RUNNING）、完成（FINISHED）、失败（FAILED）、取消（CANCELLED）
	Status *string `json:"status,omitempty"`

	// 指定作业排序字段，默认为从created_time（作业提交时间），支持duration（作业运行时长）、created_time（作业提交时间） 、job_name（作业名称）三种排序字段。
	OrderBy *string `json:"order_by,omitempty"`

	// 指定作业排序的升降序，默认为desc（降序），支持asc（升序）、desc（降序）两种排序方式。
	Order *ListRunsRequestOrder `json:"order,omitempty"`

	// 作业名称
	JobName *string `json:"job_name,omitempty"`
}

Request Object

func (ListRunsRequest) String 

func (o ListRunsRequest) String() string

type ListRunsRequestOrder 

type ListRunsRequestOrder struct {
	// contains filtered or unexported fields
}

func (ListRunsRequestOrder) MarshalJSON 

func (c ListRunsRequestOrder) MarshalJSON() ([]byte, error)

func (*ListRunsRequestOrder) UnmarshalJSON 

func (c *ListRunsRequestOrder) UnmarshalJSON(b []byte) error

func (ListRunsRequestOrder) Value added in v0.0.90 

func (c ListRunsRequestOrder) Value() string

type ListRunsRequestOrderEnum 

type ListRunsRequestOrderEnum struct {
	ASC  ListRunsRequestOrder
	DESC ListRunsRequestOrder
}

func GetListRunsRequestOrderEnum 

func GetListRunsRequestOrderEnum() ListRunsRequestOrderEnum

type ListRunsResponse 

type ListRunsResponse struct {

	// 作业总个数。
	Count *int64 `json:"count,omitempty"`

	// 作业运行列表。
	Runs           *[]Run `json:"runs,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListRunsResponse) String 

func (o ListRunsResponse) String() string

type ListTablesRequest 

type ListTablesRequest struct {

	// 过滤表名称的关键词。
	Keyword *string `json:"keyword,omitempty"`

	// 过滤标签的关键字
	Tag *string `json:"tag,omitempty"`

	// 当前偏移量，默认为0。
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的最大作业个数，范围: [1, 100]。默认值：10。
	Limit *int32 `json:"limit,omitempty"`

	// 指定作业排序字段，默认为created_time（作业创建时间），支持created_time(作业创建时间)、modified_time（作业更新时间） 、job_name（作业名称）三种排序字段。
	OrderBy *string `json:"order_by,omitempty"`

	// 指定作业排序的升降序，默认为desc（降序），支持asc（升序）、desc（降序）两种排序方式。
	Order *string `json:"order,omitempty"`
}

Request Object

func (ListTablesRequest) String 

func (o ListTablesRequest) String() string

type ListTablesResponse 

type ListTablesResponse struct {

	// 表的信息。
	Tables *[]Table `json:"tables,omitempty"`

	// 数据表总数。
	Count          *int64 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListTablesResponse) String 

func (o ListTablesResponse) String() string

type ListTagValuesRequest 

type ListTagValuesRequest struct {

	// 存储ID
	DataStoreId string `json:"data_store_id"`

	// tag 名称
	TagName string `json:"tag_name"`

	// 查询标签的值的过滤条件，例如: {\"deviceCategory\": \"class1\"}，注意特殊字符需要 urlencode
	Filters *string `json:"filters,omitempty"`

	// 查询起始元素的偏移
	Offset *int32 `json:"offset,omitempty"`

	// 返回的元素列表大小限制,默认为 100
	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ListTagValuesRequest) String 

func (o ListTagValuesRequest) String() string

type ListTagValuesResponse 

type ListTagValuesResponse struct {

	// 标签的名称
	TagName *string `json:"tag_name,omitempty"`

	// 标签的值列表
	TagValues *[]string `json:"tag_values,omitempty"`

	// 当前列表元素总数
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListTagValuesResponse) String 

func (o ListTagValuesResponse) String() string

type Metric 

type Metric struct {

	// 指标名称
	Name *string `json:"name,omitempty"`

	// 指标值类型
	Type *string `json:"type,omitempty"`

	// 指标描述
	Description *string `json:"description,omitempty"`

	// 指标单位
	Unit *string `json:"unit,omitempty"`
}

func (Metric) String 

func (o Metric) String() string

type MetricInput 

type MetricInput struct {

	// 指标计算表达式的入参名称
	Name string `json:"name"`

	// 入参所对应的资产属性名称
	PropertyName string `json:"property_name"`
}

定义指标计算查询的输入资产属性

func (MetricInput) String 

func (o MetricInput) String() string

type MetricList 

type MetricList struct {

	// metric 名称
	MetricName *string `json:"metric_name,omitempty"`

	// 计算结果
	Values *[]interface{} `json:"values,omitempty"`
}

func (MetricList) String 

func (o MetricList) String() string

type MetricValue 

type MetricValue struct {

	// 指标名称
	MetricName *string `json:"metric_name,omitempty"`

	// 计算结果，示例：[1,2]
	Values *[]interface{} `json:"values,omitempty"`
}

func (MetricValue) String 

func (o MetricValue) String() string

type ModelArtsContentReq 

type ModelArtsContentReq struct {

	// 服务名称
	ServiceName string `json:"service_name"`

	// 访问地址
	AccessAddress string `json:"access_address"`

	// 校验参数
	VerifyBody string `json:"verify_body"`

	// 租户的AK
	Ak string `json:"ak"`

	// 租户的SK
	Sk string `json:"sk"`

	// 项目id
	ProjectId string `json:"project_id"`
}

ModelArts数据源配置内容

func (ModelArtsContentReq) String 

func (o ModelArtsContentReq) String() string

type ModelArtsContentRsp 

type ModelArtsContentRsp struct {

	// 服务名称
	ServiceName *string `json:"serviceName,omitempty"`

	// 访问地址
	AccessAddress *string `json:"accessAddress,omitempty"`

	// 校验参数
	VerifyBody *string `json:"verifyBody,omitempty"`

	// 租户的AK
	Ak *string `json:"ak,omitempty"`

	// 租户的SK
	Sk *string `json:"sk,omitempty"`

	// 项目id
	ProjectId *string `json:"projectId,omitempty"`
}

SMN数据源配置内容

func (ModelArtsContentRsp) String 

func (o ModelArtsContentRsp) String() string

type NamedFormula 

type NamedFormula struct {

	// 公式名称，不能和输入参数名重复，正则：\"^[A-Za-z][A-Za-z_]{0,31}$\"
	Name string `json:"name"`

	// 公式，最多1024个字符
	Formula string `json:"formula"`
}

带名称的公式

func (NamedFormula) String 

func (o NamedFormula) String() string

type NodeContentReq 

type NodeContentReq struct {

	// 节点实例ID
	SiteId string `json:"site_id"`

	// SQL列表，将指定边缘平台节点的数字孪生模型实例数据转发到中心平台节点。
	Sqllist []string `json:"sqllist"`
}

节点数据源请求内容

func (NodeContentReq) String 

func (o NodeContentReq) String() string

type NodeContentRsp 

type NodeContentRsp struct {

	// 节点实例ID
	SiteId *string `json:"site_id,omitempty"`

	// SQL列表，将指定边缘平台节点的数字孪生模型实例数据转发到中心平台节点。
	Sqllist *[]string `json:"sqllist,omitempty"`
}

节点数据源配置内容

func (NodeContentRsp) String 

func (o NodeContentRsp) String() string

type ObsContentReq 

type ObsContentReq struct {

	// 桶名称
	BucketName string `json:"bucket_name"`

	// 租户的AK
	Ak string `json:"ak"`

	// 租户的SK
	Sk string `json:"sk"`
}

OBS数据源配置内容

func (ObsContentReq) String 

func (o ObsContentReq) String() string

type ObsContentRsp 

type ObsContentRsp struct {

	// 桶名称
	BucketName *string `json:"bucketName,omitempty"`

	// 租户的AK
	Ak *string `json:"ak,omitempty"`

	// 租户的SK
	Sk *string `json:"sk,omitempty"`
}

OBS数据源配置内容

func (ObsContentRsp) String 

func (o ObsContentRsp) String() string

type OutputRequest 

type OutputRequest struct {

	// 输出参数名称,formulas中定义的name
	Name string `json:"name"`

	// 输出资产ID，填写模型中定义的输出模型对应的某资产ID；创建资产时，如果是输出到本资产的模型，且output_static_asset_id和output_dynamic_asset_id都未配置，则后台自动配置output_static_asset_id为本资产ID；修改资产时，如果output_static_asset_id为null则表示置空
	OutputStaticAssetId *string `json:"output_static_asset_id,omitempty"`

	// 输出资产ID，填写公式动态生成资产ID，可根据入参获取资产ID，如：GetAssetId(\"assetmodelName1\",\"staticPropertyName1\",paramA)；修改资产时，如果output_static_asset_id为null则表示置空
	OutputDynamicAssetId *string `json:"output_dynamic_asset_id,omitempty"`
}

输出配置请求

func (OutputRequest) String 

func (o OutputRequest) String() string

type OutputResponse 

type OutputResponse struct {

	// 输出参数名称,formulas中定义的name
	Name string `json:"name"`

	// 输出资产ID，填写模型中定义的输出模型对应的某资产ID；创建资产时，如果是输出到本资产的模型，且output_static_asset_id和output_dynamic_asset_id都未配置，则后台自动配置output_static_asset_id为本资产ID；修改资产时，如果output_static_asset_id为null则表示置空
	OutputStaticAssetId *string `json:"output_static_asset_id,omitempty"`

	// 输出资产ID，填写公式动态生成资产ID，可根据入参获取资产ID，如：GetAssetId(\"assetmodelName1\",\"staticPropertyName1\",paramA)；修改资产时，如果output_static_asset_id为null则表示置空
	OutputDynamicAssetId *string `json:"output_dynamic_asset_id,omitempty"`

	// 输出模型ID，如果输出到本模型可以不携带
	OutputAssetModelId *string `json:"output_asset_model_id,omitempty"`

	// 输出属性名
	OutputProperty *string `json:"output_property,omitempty"`
}

输出配置响应

func (OutputResponse) String 

func (o OutputResponse) String() string

type OutputWithModel 

type OutputWithModel struct {

	// 输出参数名称,formulas中定义的name
	Name string `json:"name"`

	// 输出模型ID，如果输出到本模型可以不携带；使用导入模型和导出模型接口时，该字段无效
	OutputAssetModelId *string `json:"output_asset_model_id,omitempty"`

	// 输出模型名称，请求中携带该字段时可以不携带output_asset_model_id
	OutputAssetModelName *string `json:"output_asset_model_name,omitempty"`

	// 输出属性名
	OutputProperty string `json:"output_property"`
}

输出映射

func (OutputWithModel) String 

func (o OutputWithModel) String() string

type PipelineJobInfoDto 

type PipelineJobInfoDto struct {

	// 管道ID
	PipelineId *string `json:"pipeline_id,omitempty"`

	// 管道名称
	PipelineName *string `json:"pipeline_name,omitempty"`

	// 数据源ID
	DataSourceId *string `json:"data_source_id,omitempty"`

	// 存储列表
	DataStoreList *[]DataStoreDto `json:"data_store_list,omitempty"`

	// 管道描述
	PipelineDescription *string `json:"pipeline_description,omitempty"`

	// 存储列表
	TagList *[]TagInfoDto `json:"tag_list,omitempty"`

	// 管道状态
	PipelineState *string `json:"pipeline_state,omitempty"`

	// 操作状态
	Status *string `json:"status,omitempty"`

	// 运行管道的RTU个数
	Rtu *int32 `json:"rtu,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 用户ID
	UserId *string `json:"user_id,omitempty"`

	// 已停止的管道作业是否有历史缓存数据
	HasSavepoint *bool `json:"has_savepoint,omitempty"`
}

管道作业基础信息，包括：管道ID、管道名称、管道类型等。

func (PipelineJobInfoDto) String 

func (o PipelineJobInfoDto) String() string

type Property 

type Property struct {

	// 属性名称
	Name *string `json:"name,omitempty"`

	// 属性值类型
	Type *string `json:"type,omitempty"`

	// 属性描述
	Description *string `json:"description,omitempty"`

	// 属性单位
	Unit *string `json:"unit,omitempty"`
}

func (Property) String 

func (o Property) String() string

type PropertyFilter 

type PropertyFilter struct {

	// 过滤属性名称，正则：\"^[a-zA-Z0-9_]{1,64}$\"
	PropertyName string `json:"property_name"`

	// 过滤操作方式,当前仅支持“=”
	Operator string `json:"operator"`

	// 过滤属性值
	Value *interface{} `json:"value"`
}

属性过滤器

func (PropertyFilter) String 

func (o PropertyFilter) String() string

type PropertyModelRequest 

type PropertyModelRequest struct {

	// 属性名称，正则：\"^[a-zA-Z0-9_]{1,64}$\"
	Name string `json:"name"`

	// 属性显示名称，正则：\"^[\\\\u4E00-\\\\u9FA5A-Za-z0-9_@#.-]{1,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 属性类别，静态配置（static）、测量数据（measurement）、分析任务（analysis）
	SourceType string `json:"source_type"`

	DataSchema *DataSchema `json:"data_schema"`

	// 单位
	Unit *string `json:"unit,omitempty"`

	// 静态属性的值，如：1 1.1 \"value\" {\"name\":\"value\"}
	Value *interface{} `json:"value,omitempty"`

	// 属性是否为标签。资产ID、标签属性、时间戳三者组成属性数据唯一键，两条唯一键相同的属性数据以覆盖方式存储；一个模型中只能配置三个属性为标签，标签配置后标签不能删除，配置标签的属性也不能删除；只有integer、double、string类型的属性可以被配置为标签。示例： 资产ID asset1上依次上报如下六组数据： 资产ID 属性A（标签） 属性B    属性C 时间戳 asset1 valueA_1     valueB_1  valueC_1 T1 asset1 valueA_1     valueB_2  valueC_2 T2 asset1 valueA_2     valueB_3  valueC_3 T2 asset1 valueA_2     valueB_4  valueC_4 T2 asset1              valueB_5  valueC_5 T3 asset1              valueB_6  valueC_6 T3 根据唯一键规则最终存储为如下四组数据： 资产ID 属性A（标签） 属性B    属性C 时间戳 asset1 valueA_1     valueB_1  valueC_1 T1 asset1 valueA_1     valueB_2  valueC_2 T2 asset1 valueA_2     valueB_4  valueC_4 T2 asset1              valueB_6  valueC_6 T3
	IsTag *bool `json:"is_tag,omitempty"`
}

func (PropertyModelRequest) String 

func (o PropertyModelRequest) String() string

type PropertyModelResponse 

type PropertyModelResponse struct {

	// 属性名称，正则：\"^[a-zA-Z0-9_]{1,64}$\"
	Name string `json:"name"`

	// 属性显示名称，正则：\"^[\\\\u4E00-\\\\u9FA5A-Za-z0-9_@#.-]{1,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 属性类别，静态配置（static）、测量数据（measurement）、分析任务（analysis）
	SourceType string `json:"source_type"`

	DataSchema *DataSchema `json:"data_schema"`

	// 单位
	Unit *string `json:"unit,omitempty"`

	// 静态属性的值，如：1 1.1 \"value\" {\"name\":\"value\"}
	Value *interface{} `json:"value,omitempty"`

	// 属性是否为标签。资产ID、标签属性、时间戳三者组成属性数据唯一键，两条唯一键相同的属性数据以覆盖方式存储；一个模型中只能配置三个属性为标签，标签配置后标签不能删除，配置标签的属性也不能删除；只有integer、double、string类型的属性可以被配置为标签。示例： 资产ID asset1上依次上报如下六组数据： 资产ID 属性A（标签） 属性B    属性C 时间戳 asset1 valueA_1     valueB_1  valueC_1 T1 asset1 valueA_1     valueB_2  valueC_2 T2 asset1 valueA_2     valueB_3  valueC_3 T2 asset1 valueA_2     valueB_4  valueC_4 T2 asset1              valueB_5  valueC_5 T3 asset1              valueB_6  valueC_6 T3 根据唯一键规则最终存储为如下四组数据： 资产ID 属性A（标签） 属性B    属性C 时间戳 asset1 valueA_1     valueB_1  valueC_1 T1 asset1 valueA_1     valueB_2  valueC_2 T2 asset1 valueA_2     valueB_4  valueC_4 T2 asset1              valueB_6  valueC_6 T3
	IsTag *bool `json:"is_tag,omitempty"`

	// 属性ID
	PropertyId *string `json:"property_id,omitempty"`
}

func (PropertyModelResponse) String 

func (o PropertyModelResponse) String() string

type PropertyReferenceModel 

type PropertyReferenceModel struct {

	// 属性引用类型，引用本资产属性（this）、引用其他资产属性（single）、引用子资产属性（children）
	Type string `json:"type"`

	// 引用属性所属的资产模型ID，该字段仅当type为“引用其他资产属性”或“引用子资产属性”时有效；使用导入模型和导出模型接口时，该字段无效
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 引用属性所属的资产模型名称，请求中携带该字段时可以不携带asset_model_id字段
	AssetModelName *string `json:"asset_model_name,omitempty"`

	// 引用属性的名称
	PropertyName string `json:"property_name"`
}

属性引用

func (PropertyReferenceModel) String 

func (o PropertyReferenceModel) String() string

type PropertyReferenceReq 

type PropertyReferenceReq struct {

	// 引用的资产ID，只有single型参数才能填写，可填写null置空
	AssetId *string `json:"asset_id,omitempty"`
}

属性引用

func (PropertyReferenceReq) String 

func (o PropertyReferenceReq) String() string

type PropertyReferenceResponse 

type PropertyReferenceResponse struct {

	// 属性引用类型，引用本资产属性（this）、引用其他资产属性（single）、引用子资产属性（children）
	Type string `json:"type"`

	// 引用属性所属的资产模型ID，该字段仅当type为“引用其他资产属性”或“引用子资产属性”时有效；使用导入模型和导出模型接口时，该字段无效
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 引用属性所属的资产模型名称，请求中携带该字段时可以不携带asset_model_id字段
	AssetModelName *string `json:"asset_model_name,omitempty"`

	// 引用属性的名称
	PropertyName string `json:"property_name"`

	// 引用的资产ID，修改资产时携带null表示置空
	AssetId *string `json:"asset_id,omitempty"`
}

属性引用

func (PropertyReferenceResponse) String 

func (o PropertyReferenceResponse) String() string

type PropertyRequest 

type PropertyRequest struct {

	// 属性名称，必须是模型中已存在的
	Name string `json:"name"`

	// 值，只有static型属性可以填写
	Value *interface{} `json:"value,omitempty"`

	// 设备ID，只有measurement型属性可以填写
	DeviceId *string `json:"device_id,omitempty"`
}

func (PropertyRequest) String 

func (o PropertyRequest) String() string

type PropertyResponse 

type PropertyResponse struct {

	// 设备ID
	DeviceId *string `json:"device_id,omitempty"`

	// 属性ID
	PropertyId *string `json:"property_id,omitempty"`

	// 属性名称，正则：\"^[a-zA-Z0-9_]{1,64}$\"
	Name string `json:"name"`

	// 属性显示名称，正则：\"^[\\\\u4E00-\\\\u9FA5A-Za-z0-9_@#.-]{1,64}$\"
	DisplayName *string `json:"display_name,omitempty"`

	// 属性类别，静态配置（static）、测量数据（measurement）、分析任务（analysis）
	SourceType string `json:"source_type"`

	DataSchema *DataSchema `json:"data_schema"`

	// 单位
	Unit *string `json:"unit,omitempty"`

	// 静态属性的值，如：1 1.1 \"value\" {\"name\":\"value\"}
	Value *interface{} `json:"value,omitempty"`

	// 属性是否为标签。资产ID、标签属性、时间戳三者组成属性数据唯一键，两条唯一键相同性数据以覆盖方式存储；一个模型中只能配置三个属性为标签，标签配置后标签不能删除，配置标签性也不能删除；只有integer、double、string类型的属性可以被配置为标签。示例： 资产ID asset1上依次上报如下六组数据： 资产ID 属性A（标签） 属性B    属性C 时间戳 asset1 valueA_1     valueB_1  valueC_1 T1 asset1 valueA_1     valueB_2  valueC_2 T2 asset1 valueA_2     valueB_3  valueC_3 T2 asset1 valueA_2     valueB_4  valueC_4 T2 asset1              valueB_5  valueC_5 T3 asset1              valueB_6  valueC_6 T3 根据唯一键规则最终存储为如下四组数据： 资产ID 属性A（标签） 属性B    属性C 时间戳 asset1 valueA_1     valueB_1  valueC_1 T1 asset1 valueA_1     valueB_2  valueC_2 T2 asset1 valueA_2     valueB_4  valueC_4 T2 asset1              valueB_6  valueC_6 T3
	IsTag *bool `json:"is_tag,omitempty"`
}

func (PropertyResponse) String 

func (o PropertyResponse) String() string

type PropertyValue 

type PropertyValue struct {

	// 属性名称
	PropertyName *string `json:"property_name,omitempty"`

	// 属性值
	Value *interface{} `json:"value,omitempty"`

	// 属性值最后更新时间
	Timestamp *string `json:"timestamp,omitempty"`
}

func (PropertyValue) String 

func (o PropertyValue) String() string

type PublishRootAssetRequest 

type PublishRootAssetRequest struct {

	// 根资产ID
	RootAssetId string `json:"root_asset_id"`
}

Request Object

func (PublishRootAssetRequest) String 

func (o PublishRootAssetRequest) String() string

type PublishRootAssetResponse 

type PublishRootAssetResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (PublishRootAssetResponse) String 

func (o PublishRootAssetResponse) String() string

type RawRequest 

type RawRequest struct {
	TimeSpan *TimeSpanDt `json:"time_span,omitempty"`

	// 对property按指定tags标签进行过滤查询，填入资产标签属性的属性名与属性值，不可为空，例如 {\"tagPropertyA\": \"id0001\"}；注意，标签过滤只对打上标签时刻之后的数据生效，打标签之前的数据不能通过标签过滤
	Tags map[string]interface{} `json:"tags,omitempty"`

	// 属性过滤器，最多5个
	PropertyFilter *[]PropertyFilter `json:"property_filter,omitempty"`

	// 待查询的资产属性列表
	PropertyNames []string `json:"property_names"`

	// 返回值个数限制
	Limit *int32 `json:"limit,omitempty"`
}

资产属性历史数据查询

func (RawRequest) String 

func (o RawRequest) String() string

type RawValue 

type RawValue struct {

	// 属性名称
	PropertyName *string `json:"property_name,omitempty"`

	// 资产属性的历史值序列，示例：[1,2]
	Values *[]interface{} `json:"values,omitempty"`
}

func (RawValue) String 

func (o RawValue) String() string

type Run 

type Run struct {

	// 作业运行ID。
	RunId string `json:"run_id"`

	// 作业ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业名称。
	JobName string `json:"job_name"`

	// 作业类型。
	JobType RunJobType `json:"job_type"`

	// 作业开始的时间。时间格式为ISO日期时间格式yyyy-MM-dd'T'HH:mm:ss'Z'
	StartTime string `json:"start_time"`

	// 作业运行时长，单位毫秒。
	Duration int64 `json:"duration"`

	// 此作业的当前状态，包含提交（LAUNCHING）、运行中（RUNNING）、完成（FINISHED）、失败（FAILED）、取消（CANCELLED）。
	Status string `json:"status"`

	// 是否定时作业。
	IsScheduleJob *bool `json:"is_schedule_job,omitempty"`

	// 计算资源名称。
	ComputingResourceName *string `json:"computing_resource_name,omitempty"`

	SqlJob *SqlJobRun `json:"sql_job,omitempty"`
}

func (Run) String 

func (o Run) String() string

type RunDetail 

type RunDetail struct {

	// 作业运行详情ID。
	DetailId string `json:"detail_id"`

	// 此作业的当前状态，包含提交（LAUNCHING）、运行中（RUNNING）、完成（FINISHED）、失败（FAILED）、取消（CANCELLED）。
	Status *string `json:"status,omitempty"`

	SqlJob *SqlJobRunDetail `json:"sql_job,omitempty"`
}

func (RunDetail) String 

func (o RunDetail) String() string

type RunJobType 

type RunJobType struct {
	// contains filtered or unexported fields
}

func (RunJobType) MarshalJSON 

func (c RunJobType) MarshalJSON() ([]byte, error)

func (*RunJobType) UnmarshalJSON 

func (c *RunJobType) UnmarshalJSON(b []byte) error

func (RunJobType) Value added in v0.0.90 

func (c RunJobType) Value() string

type RunJobTypeEnum 

type RunJobTypeEnum struct {
	SQL_JOB RunJobType
}

func GetRunJobTypeEnum 

func GetRunJobTypeEnum() RunJobTypeEnum

type SaslPlainAuthInfo 

type SaslPlainAuthInfo struct {

	// 用户名。支持大小写字母、数字、“.”、“-” 、“_”
	Username *string `json:"username,omitempty"`

	// 密码
	Password *string `json:"password,omitempty"`
}

sasl plain 认证信息

func (SaslPlainAuthInfo) String 

func (o SaslPlainAuthInfo) String() string

type Schedule 

type Schedule struct {

	// 调度开始时间。时间格式为ISO时区日期时间。例如2021-03-03T10:15:30+08:00
	StartTime string `json:"start_time"`

	// 调度结束时间。时间格式为ISO时区日期时间。例如2021-03-03T10:15:30+08:00
	EndTime string `json:"end_time"`

	// Cron表达式，格式为<秒> <分> <时> <天> <月> <星期>
	CronExpression string `json:"cron_expression"`

	// 计算资源ID。
	ComputingResourceId string `json:"computing_resource_id"`

	// 调度启用状态. true: 调度中；false：停止调度。
	Enable bool `json:"enable"`

	// 作业运行配置信息。
	Conf *[]string `json:"conf,omitempty"`

	// 仅在查询作业和查询所有作业接口的响应返回。调度状态。1:NORMAL, 2:PAUSED, 3:COMPLETE, 4:ERROR, 5:BLOCKED
	ScheduleStatus *string `json:"schedule_status,omitempty"`

	// 仅在查询作业和查询所有作业接口的响应返回。上一次调度开始时间。
	NextFireTime *string `json:"next_fire_time,omitempty"`

	// 仅在查询作业和查询所有作业接口的响应返回。下一次调度开始时间。
	PrevFireTime *string `json:"prev_fire_time,omitempty"`
}

SQL作业。

func (Schedule) String 

func (o Schedule) String() string

type ShowAllDataSourceRequest 

type ShowAllDataSourceRequest struct {

	// filter
	Name *string `json:"name,omitempty"`

	// 数据源类型, 包括：OBS、DIS、IOTDA、SMN、FUNCTION_GRAPH、MODEL_ARTS、DCS、KAFKA、API
	Type *string `json:"type,omitempty"`

	// 每次查询返回元素的上限
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量，表示从此偏移量开始查询，offset大于等于0
	Offset *int32 `json:"offset,omitempty"`
}

Request Object

func (ShowAllDataSourceRequest) String 

func (o ShowAllDataSourceRequest) String() string

type ShowAllDataSourceResponse 

type ShowAllDataSourceResponse struct {

	// 总数
	Count *int32 `json:"count,omitempty"`

	// 数据源列表
	Datasources    *[]DatasourceRestDto `json:"datasources,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

Response Object

func (ShowAllDataSourceResponse) String 

func (o ShowAllDataSourceResponse) String() string

type ShowAssetModelRequest 

type ShowAssetModelRequest struct {

	// 模型ID
	ModelId string `json:"model_id"`
}

Request Object

func (ShowAssetModelRequest) String 

func (o ShowAssetModelRequest) String() string

type ShowAssetModelResponse 

type ShowAssetModelResponse struct {

	// 模型ID
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 模型名称
	Name *string `json:"name,omitempty"`

	// 模型显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集
	Properties *[]PropertyModelResponse `json:"properties,omitempty"`

	// 分析任务集
	Analyses *[]AnalysisModelResponse `json:"analyses,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ShowAssetModelResponse) String 

func (o ShowAssetModelResponse) String() string

type ShowAssetNewRequest 

type ShowAssetNewRequest struct {

	// 资产ID
	AssetId string `json:"asset_id"`

	// SKETCH：草稿态；RELEASE：发布态
	Type string `json:"type"`
}

Request Object

func (ShowAssetNewRequest) String 

func (o ShowAssetNewRequest) String() string

type ShowAssetNewResponse 

type ShowAssetNewResponse struct {

	// 资产ID
	AssetId *string `json:"asset_id,omitempty"`

	// 资产模型ID
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 资产模型名称
	AssetModelName *string `json:"asset_model_name,omitempty"`

	// 资产名称
	Name *string `json:"name,omitempty"`

	// 资产显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集
	Properties *[]PropertyResponse `json:"properties,omitempty"`

	// 分析任务集
	Analyses *[]AnalysisResponse `json:"analyses,omitempty"`

	// 根资产ID
	Root *string `json:"root,omitempty"`

	// 父资产ID，根资产的父资产ID为null
	Parent *string `json:"parent,omitempty"`

	// 子资产ID集
	Children *[]string `json:"children,omitempty"`

	// 资产状态，正常状态（ACTIVE），异常状态（INACTIVE）；只有草稿态（SKETCH）资产有此状态；资产处于异常状态的场景有：1、该资产存在未填写设备ID的测量数据类别的属性；2、该资产存在未填写静态值的静态配置类别的属性；3、该资产存在分析任务，该分析任务的输入参数存在属性引用类型为引用其他资产属性，且没有为该输入参数配置引用的其他资产的资产ID
	State *string `json:"state,omitempty"`

	// 资产发布状态，发布中（PUBLISHING），发布完成（PUBLISHED）；只能对草稿态（SKETCH）的根资产进行发布，也只有草稿态的根资产有此字段；如果根资产从未发布过则值为null
	PublishState *string `json:"publish_state,omitempty"`

	// 创建时间，格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间，格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 发布时间，只能对草稿态（SKETCH）的根资产进行发布，也只有草稿态的根资产有此字段；如果从未发布过则值为null；格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	PublishedTime  *string `json:"published_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ShowAssetNewResponse) String 

func (o ShowAssetNewResponse) String() string

type ShowBatchJobRequest 

type ShowBatchJobRequest struct {

	// 数据开发任务ID。
	JobId string `json:"job_id"`
}

Request Object

func (ShowBatchJobRequest) String 

func (o ShowBatchJobRequest) String() string

type ShowBatchJobResponse 

type ShowBatchJobResponse struct {

	// 仅在响应返回。作业ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业名称。只能包含数字、英文字母、中文字母、下划线以及中划线。长度为1~128。
	JobName *string `json:"job_name,omitempty"`

	// 标签。只能包含数字、英文字母、中文字符、下划线、中划线、逗号以及斜杠。长度为0~128。
	Tags *string `json:"tags,omitempty"`

	// 仅在响应返回。创建时间。
	CreatedTime *string `json:"created_time,omitempty"`

	// 仅在响应返回。更新时间。
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 作业类型。目前仅支持SqlJob.
	JobType *string `json:"job_type,omitempty"`

	// 作业查询结果导出到OBS的路径。覆写已存在文件。
	ExportPath *string `json:"export_path,omitempty"`

	// 导出文件时是否合并结果文件。true：合并成一个结果文件；false：不合并结果文件。
	MergeResultFile *bool `json:"merge_result_file,omitempty"`

	SqlJob *SqlJob `json:"sql_job,omitempty"`

	Schedule       *Schedule `json:"schedule,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (ShowBatchJobResponse) String 

func (o ShowBatchJobResponse) String() string

type ShowDataSourceRequest 

type ShowDataSourceRequest struct {

	// 数据源id
	DatasourceId string `json:"datasource_id"`
}

Request Object

func (ShowDataSourceRequest) String 

func (o ShowDataSourceRequest) String() string

type ShowDataSourceResponse 

type ShowDataSourceResponse struct {

	// 数据源id
	Id *string `json:"id,omitempty"`

	// 数据源名称
	Name *string `json:"name,omitempty"`

	// 数据源类型, 包括：IOTDA、API[、OBS、DIS、SMN、FUNCTION_GRAPH、MODEL_ARTS、DCS、KAFKA](tag:IoTA-Cloud-Only)、NODE。数据源不支持修改类型。
	Type *string `json:"type,omitempty"`

	Content *ContentDetailRsp `json:"content,omitempty"`

	// 创建时间，格式为：yyyy-MM-dd'T'HH:mm:ss'Z'
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间，格式为：yyyy-MM-dd'T'HH:mm:ss'Z'
	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ShowDataSourceResponse) String 

func (o ShowDataSourceResponse) String() string

type ShowDatasetRequest 

type ShowDatasetRequest struct {

	// 作业ID。
	JobId string `json:"job_id"`

	// 作业运行ID。
	RunId string `json:"run_id"`

	// 当前偏移量，默认为0。
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的最大作业个数，范围: [1, 100]。默认值：10。
	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ShowDatasetRequest) String 

func (o ShowDatasetRequest) String() string

type ShowDatasetResponse 

type ShowDatasetResponse struct {

	// 作业结果总个数。
	Count *int64 `json:"count,omitempty"`

	// 作业运行ID。
	RunId *string `json:"run_id,omitempty"`

	// 作业类型。
	JobType *string `json:"job_type,omitempty"`

	SqlJob         *SqlJobQueryDataset `json:"sql_job,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

Response Object

func (ShowDatasetResponse) String 

func (o ShowDatasetResponse) String() string

type ShowJobByIdRequest 

type ShowJobByIdRequest struct {

	// 作业ID
	JobId string `json:"job_id"`
}

Request Object

func (ShowJobByIdRequest) String 

func (o ShowJobByIdRequest) String() string

type ShowJobByIdResponse 

type ShowJobByIdResponse struct {

	// 实时分析作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：实时分析算子配置指南。
	JobConfig map[string]interface{} `json:"job_config,omitempty"`

	JobInfo        *StreamingJobInfoDto `json:"job_info,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

Response Object

func (ShowJobByIdResponse) String 

func (o ShowJobByIdResponse) String() string

type ShowJobsRequest 

type ShowJobsRequest struct {

	// 接收数据类型，支持两种接收数据类型：“管道数据”、“资产数据”。管道数据：“实时分析”使用来自“数据管道”的数据进行分析，并可将数据输出到其他云服务。资产数据：“实时分析”使用来自“资产模型”的数据进行分析，并将分析后的结果返回给“资产模型”，丰富资产模型。
	JobInputType *ShowJobsRequestJobInputType `json:"job_input_type,omitempty"`

	// 偏移量，表示从此偏移量开始查询，offset大于等于0
	Offset *int64 `json:"offset,omitempty"`

	// 每页显示的条目数量
	Limit *int32 `json:"limit,omitempty"`

	// 立即同步作业状态，默认是false
	SyncStatus *bool `json:"sync_status,omitempty"`
}

Request Object

func (ShowJobsRequest) String 

func (o ShowJobsRequest) String() string

type ShowJobsRequestJobInputType 

type ShowJobsRequestJobInputType struct {
	// contains filtered or unexported fields
}

func (ShowJobsRequestJobInputType) MarshalJSON 

func (c ShowJobsRequestJobInputType) MarshalJSON() ([]byte, error)

func (*ShowJobsRequestJobInputType) UnmarshalJSON 

func (c *ShowJobsRequestJobInputType) UnmarshalJSON(b []byte) error

func (ShowJobsRequestJobInputType) Value added in v0.0.90 

func (c ShowJobsRequestJobInputType) Value() string

type ShowJobsRequestJobInputTypeEnum 

type ShowJobsRequestJobInputTypeEnum struct {
	ASSET_DATA ShowJobsRequestJobInputType
	OLD_DATA   ShowJobsRequestJobInputType
}

func GetShowJobsRequestJobInputTypeEnum 

func GetShowJobsRequestJobInputTypeEnum() ShowJobsRequestJobInputTypeEnum

type ShowJobsResponse 

type ShowJobsResponse struct {

	// 总数
	Count *int64 `json:"count,omitempty"`

	// 作业列表
	Jobs           *[]StreamingJobInfoDto `json:"jobs,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (ShowJobsResponse) String 

func (o ShowJobsResponse) String() string

type ShowLastPropertyValueRequest 

type ShowLastPropertyValueRequest struct {

	// 资产ID
	AssetId string `json:"asset_id"`

	Body *LastAssetPropertyValueRequest `json:"body,omitempty"`
}

Request Object

func (ShowLastPropertyValueRequest) String 

func (o ShowLastPropertyValueRequest) String() string

type ShowLastPropertyValueResponse 

type ShowLastPropertyValueResponse struct {

	// 查询到的资产属性列表
	Properties     *[]AssetPropertyLastValue `json:"properties,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

Response Object

func (ShowLastPropertyValueResponse) String 

func (o ShowLastPropertyValueResponse) String() string

type ShowMetricValueRequest 

type ShowMetricValueRequest struct {

	// 资产ID
	AssetId string `json:"asset_id"`

	Body *GetMetricsValue `json:"body,omitempty"`
}

Request Object

func (ShowMetricValueRequest) String 

func (o ShowMetricValueRequest) String() string

type ShowMetricValueResponse 

type ShowMetricValueResponse struct {

	// 时间序列,使用UTC时间，格式：yyyy-MM-dd'T'HH:mm:ss.SSS'Z',示例：2021-02-01T00:00:00.123Z
	Timestamps *[]string `json:"timestamps,omitempty"`

	// 指标计算结果列表
	Metrics        *[]MetricValue `json:"metrics,omitempty"`
	HttpStatusCode int            `json:"-"`
}

Response Object

func (ShowMetricValueResponse) String 

func (o ShowMetricValueResponse) String() string

type ShowPipelineJobRequest 

type ShowPipelineJobRequest struct {

	// 管道ID
	PipelineId string `json:"pipeline_id"`
}

Request Object

func (ShowPipelineJobRequest) String 

func (o ShowPipelineJobRequest) String() string

type ShowPipelineJobResponse 

type ShowPipelineJobResponse struct {

	// 管道作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：数据管道算子配置指南。
	PipelineConfig map[string]interface{} `json:"pipeline_config,omitempty"`

	PipelineInfo   *PipelineJobInfoDto `json:"pipeline_info,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

Response Object

func (ShowPipelineJobResponse) String 

func (o ShowPipelineJobResponse) String() string

type ShowPropertyRawValueRequest 

type ShowPropertyRawValueRequest struct {

	// 资产ID
	AssetId string `json:"asset_id"`

	Body *RawRequest `json:"body,omitempty"`
}

Request Object

func (ShowPropertyRawValueRequest) String 

func (o ShowPropertyRawValueRequest) String() string

type ShowPropertyRawValueResponse 

type ShowPropertyRawValueResponse struct {

	// 时间序列,使用UTC时间，格式：yyyy-MM-dd'T'HH:mm:ss.SSS'Z',示例：2021-02-01T00:00:00.123Z
	Timestamps *[]string `json:"timestamps,omitempty"`

	// 响应属性列表
	Properties     *[]RawValue `json:"properties,omitempty"`
	HttpStatusCode int         `json:"-"`
}

Response Object

func (ShowPropertyRawValueResponse) String 

func (o ShowPropertyRawValueResponse) String() string

type ShowPropertyValuesRequest 

type ShowPropertyValuesRequest struct {

	// 存储ID
	DataStoreId string `json:"data_store_id"`

	Body *GetPropertyRequest `json:"body,omitempty"`
}

Request Object

func (ShowPropertyValuesRequest) String 

func (o ShowPropertyValuesRequest) String() string

type ShowPropertyValuesResponse 

type ShowPropertyValuesResponse struct {

	// 查询设备的属性值
	Properties     *[]PropertyValue `json:"properties,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (ShowPropertyValuesResponse) String 

func (o ShowPropertyValuesResponse) String() string

type ShowRunRequest 

type ShowRunRequest struct {

	// 作业ID。
	JobId string `json:"job_id"`

	// 作业运行ID。
	RunId string `json:"run_id"`

	// 是否查询作业详情。true：查询；false：不查询。details属性为空。默认为false。
	WithDetails *bool `json:"with_details,omitempty"`
}

Request Object

func (ShowRunRequest) String 

func (o ShowRunRequest) String() string

type ShowRunResponse 

type ShowRunResponse struct {

	// 作业运行ID。
	RunId *string `json:"run_id,omitempty"`

	// 作业ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业类型。
	JobType *string `json:"job_type,omitempty"`

	// 此作业的当前状态，包含提交（LAUNCHING）、运行中（RUNNING）、完成（FINISHED）、失败（FAILED）、取消（CANCELLED）。
	Status *string `json:"status,omitempty"`

	// 创建运行时间。
	CreatedTime *string `json:"created_time,omitempty"`

	// 系统提示信息。运行失败时，失败原因。
	Message *string `json:"message,omitempty"`

	// 作业运行详情。
	Details        *[]RunDetail `json:"details,omitempty"`
	HttpStatusCode int          `json:"-"`
}

Response Object

func (ShowRunResponse) String 

func (o ShowRunResponse) String() string

type ShowTablePreviewRequest 

type ShowTablePreviewRequest struct {

	// 表ID。
	TableId string `json:"table_id"`
}

Request Object

func (ShowTablePreviewRequest) String 

func (o ShowTablePreviewRequest) String() string

type ShowTablePreviewResponse 

type ShowTablePreviewResponse struct {

	// 表的列名称和类型。
	Schema *[]interface{} `json:"schema,omitempty"`

	// 预览的表内容。
	Rows           *[]interface{} `json:"rows,omitempty"`
	HttpStatusCode int            `json:"-"`
}

Response Object

func (ShowTablePreviewResponse) String 

func (o ShowTablePreviewResponse) String() string

type ShowTableSchemaRequest 

type ShowTableSchemaRequest struct {

	// 表ID。
	TableId string `json:"table_id"`
}

Request Object

func (ShowTableSchemaRequest) String 

func (o ShowTableSchemaRequest) String() string

type ShowTableSchemaResponse 

type ShowTableSchemaResponse struct {

	// 表ID。
	TableId *string `json:"table_id,omitempty"`

	// 表名。
	TableName *string `json:"table_name,omitempty"`

	// 表别名。
	TableAlias *string `json:"table_alias,omitempty"`

	// 标签。
	Tags *string `json:"tags,omitempty"`

	// 表的总列数。
	ColumnCount *int32 `json:"column_count,omitempty"`

	// 表的列信息，包含列名称、类型和描述信息。
	Columns *[]Column `json:"columns,omitempty"`

	// 表类型，包括“MANAGED”，“EXTERNAL”和“VIEW”。
	TableType *string `json:"table_type,omitempty"`

	// 数据类型，包括“csv”，“parquet”。
	DataType *string `json:"data_type,omitempty"`

	// 数据存储的路径，以“s3a”开头。
	DataLocation *string `json:"data_location,omitempty"`

	StorageProperties *[]KeyValue `json:"storage_properties,omitempty"`
	HttpStatusCode    int         `json:"-"`
}

Response Object

func (ShowTableSchemaResponse) String 

func (o ShowTableSchemaResponse) String() string

type SmnContentReq 

type SmnContentReq struct {

	// 项目id
	ProjectId string `json:"project_id"`

	// 租户的AK
	Ak string `json:"ak"`

	// 租户的SK
	Sk string `json:"sk"`
}

SMN数据源配置内容

func (SmnContentReq) String 

func (o SmnContentReq) String() string

type SmnContentRsp 

type SmnContentRsp struct {

	// 项目id
	ProjectId *string `json:"projectId,omitempty"`

	// 租户的AK
	Ak *string `json:"ak,omitempty"`

	// 租户的SK
	Sk *string `json:"sk,omitempty"`
}

SMN数据源配置内容

func (SmnContentRsp) String 

func (o SmnContentRsp) String() string

type SqlJob 

type SqlJob struct {

	// 作业的SQL。
	Sql string `json:"sql"`
}

可选。SQL作业。

func (SqlJob) String 

func (o SqlJob) String() string

type SqlJobQueryDataset 

type SqlJobQueryDataset struct {

	// 作业类型。DDL, DCL, IMPORT, EXPORT, QUERY, INSERT.
	SqlType string `json:"sql_type"`

	// 当语句类型为DDL时，返回其结果的列名称及类型。
	Schema *[]interface{} `json:"schema,omitempty"`

	// 当语句类型为DDL时，直接返回其执行结果。
	Rows *[]interface{} `json:"rows,omitempty"`
}

SQL作业运行结果。

func (SqlJobQueryDataset) String 

func (o SqlJobQueryDataset) String() string

type SqlJobRun 

type SqlJobRun struct {

	// 作业类型。DDL, DCL, IMPORT, EXPORT, QUERY, INSERT.
	SqlType string `json:"sql_type"`
}

SQL作业运行。

func (SqlJobRun) String 

func (o SqlJobRun) String() string

type SqlJobRunDetail 

type SqlJobRunDetail struct {

	// 作业类型。
	SqlType *string `json:"sql_type,omitempty"`

	// 作业开始的时间。时间格式为ISO日期时间格式yyyy-MM-dd'T'HH:mm:ss'Z'
	StartTime *string `json:"start_time,omitempty"`

	// 作业运行时长，单位毫秒。
	Duration *int64 `json:"duration,omitempty"`

	// Insert作业执行过程中扫描的记录条数。
	InputRowCount *int64 `json:"input_row_count,omitempty"`

	// Insert作业执行过程中扫描到的错误记录数。
	BadRowCount *int64 `json:"bad_row_count,omitempty"`

	// 作业执行过程中扫描文件的大小。
	InputSize *int64 `json:"input_size,omitempty"`

	// 当前作业返回的结果总条数或insert作业插入的总条数。
	ResultCount *int64 `json:"result_count,omitempty"`

	// 记录其操作的表名称。类型为Import和Export作业才有“table_name”属性。
	TableName *string `json:"table_name,omitempty"`

	// Import类型的作业，记录其导入的数据是否包括列名。
	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	// SQL查询的相关列信息的Json字符串。
	Detail *string `json:"detail,omitempty"`

	// 作业执行的SQL语句。
	Statement *string `json:"statement,omitempty"`

	// 系统提示信息。运行失败时，失败原因。
	Message *string `json:"message,omitempty"`
}

func (SqlJobRunDetail) String 

func (o SqlJobRunDetail) String() string

type SqlJobRunResponseBody 

type SqlJobRunResponseBody struct {

	// 作业类型。DDL, DCL, IMPORT, EXPORT, QUERY, INSERT.
	SqlType string `json:"sql_type"`

	// 当语句类型为DDL时，返回其结果的列名称及类型。
	Schema *[]interface{} `json:"schema,omitempty"`

	// 当语句类型为DDL时，直接返回其执行结果。
	Rows *[]interface{} `json:"rows,omitempty"`

	// 作业执行模式：async: 异步; sync: 同步。
	JobMode *string `json:"job_mode,omitempty"`
}

SQL作业运行响应。

func (SqlJobRunResponseBody) String 

func (o SqlJobRunResponseBody) String() string

type StartJobRequest 

type StartJobRequest struct {

	// 作业ID
	JobId string `json:"job_id"`

	// 运行作业的并发度
	Parallel *int32 `json:"parallel,omitempty"`

	// 运行作业的RTU个数
	Rtu *int32 `json:"rtu,omitempty"`

	// 运行作业使用历史缓存数据
	ResumeSavepoint *bool `json:"resume_savepoint,omitempty"`
}

Request Object

func (StartJobRequest) String 

func (o StartJobRequest) String() string

type StartJobResponse 

type StartJobResponse struct {

	// 作业ID
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (StartJobResponse) String 

func (o StartJobResponse) String() string

type StartPipelineJobRequest 

type StartPipelineJobRequest struct {

	// 管道ID
	PipelineId string `json:"pipeline_id"`

	// 运行管道的并发度
	Parallel *int32 `json:"parallel,omitempty"`

	// 运行管道的RTU个数
	Rtu *int32 `json:"rtu,omitempty"`

	// 运行管道作业使用历史缓存数据
	ResumeSavepoint *bool `json:"resume_savepoint,omitempty"`
}

Request Object

func (StartPipelineJobRequest) String 

func (o StartPipelineJobRequest) String() string

type StartPipelineJobResponse 

type StartPipelineJobResponse struct {

	// 管道ID
	PipelineId     *string `json:"pipeline_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (StartPipelineJobResponse) String 

func (o StartPipelineJobResponse) String() string

type StopJobRequest 

type StopJobRequest struct {

	// 作业ID
	JobId string `json:"job_id"`

	// 停止作业触发savepoint
	TriggerSavepoint *bool `json:"trigger_savepoint,omitempty"`
}

Request Object

func (StopJobRequest) String 

func (o StopJobRequest) String() string

type StopJobResponse 

type StopJobResponse struct {

	// 作业ID
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (StopJobResponse) String 

func (o StopJobResponse) String() string

type StopPipelineJobRequest 

type StopPipelineJobRequest struct {

	// 管道ID
	PipelineId string `json:"pipeline_id"`

	// 停止管道作业触发savepoint
	TriggerSavepoint *bool `json:"trigger_savepoint,omitempty"`
}

Request Object

func (StopPipelineJobRequest) String 

func (o StopPipelineJobRequest) String() string

type StopPipelineJobResponse 

type StopPipelineJobResponse struct {

	// 管道ID
	PipelineId     *string `json:"pipeline_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (StopPipelineJobResponse) String 

func (o StopPipelineJobResponse) String() string

type StorageGroup 

type StorageGroup struct {

	// 存储组名称
	Name *string `json:"name,omitempty"`

	// 描述
	Description *string `json:"description,omitempty"`

	// 温数据老化策略，单位只支持d（天），且只支持整数，如365天则可配置为“365d”，如“365h”或“360.5d”等均不被支持
	WarmDataRetentionPolicy *string `json:"warm_data_retention_policy,omitempty"`

	// 冷数据老化策略，单位只支持d（天），且只支持整数，如365天则可配置为“365d”，如“365h”或“360.5d”等均不被支持
	ColdDataRetentionPolicy *string `json:"cold_data_retention_policy,omitempty"`
}

存储组信息

func (StorageGroup) String 

func (o StorageGroup) String() string

type StreamModel 

type StreamModel struct {

	// 输入参数，最多支持10个；流计算的输入参数名需要在接收数据类型为资产数据的实时分析作业中定义，模型中必须与其保持一致
	Inputs []InputModel `json:"inputs"`

	// 实时分析作业ID
	JobId string `json:"job_id"`

	// 输出属性，最多支持10个
	Outputs []StreamOutput `json:"outputs"`
}

流计算

func (StreamModel) String 

func (o StreamModel) String() string

type StreamOutput 

type StreamOutput struct {

	// 输出参数名称，必须是接收数据类型为资产数据的实时分析作业中已定义的
	Name string `json:"name"`

	// 输出属性名，必须是本模型分析任务类别的属性的属性名
	OutputProperty string `json:"output_property"`
}

流计算输出映射

func (StreamOutput) String 

func (o StreamOutput) String() string

type StreamResponse 

type StreamResponse struct {

	// 输入参数
	Inputs *[]InputResponse `json:"inputs,omitempty"`

	// 流计算任务ID
	JobId *string `json:"job_id,omitempty"`

	// 输出属性，最多支持10个
	Outputs *[]StreamOutput `json:"outputs,omitempty"`
}

流计算

func (StreamResponse) String 

func (o StreamResponse) String() string

type StreamingJobInfoDto 

type StreamingJobInfoDto struct {

	// 作业ID
	JobId *string `json:"job_id,omitempty"`

	// 作业名称
	JobName *string `json:"job_name,omitempty"`

	// 接收数据类型
	JobInputType *string `json:"job_input_type,omitempty"`

	// 作业描述
	JobDescription *string `json:"job_description,omitempty"`

	// 作业状态
	JobState *string `json:"job_state,omitempty"`

	// 操作状态
	Status *string `json:"status,omitempty"`

	// 运行作业的RTU个数
	Rtu *int32 `json:"rtu,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 用户ID
	UserId *string `json:"user_id,omitempty"`

	// 已停止作业是否有历史缓存数据
	HasSavepoint *bool `json:"has_savepoint,omitempty"`
}

实时分析作业基础信息，包括：实时分析作业ID、实时分析作业名称、作业类型等。

func (StreamingJobInfoDto) String 

func (o StreamingJobInfoDto) String() string

type Table 

type Table struct {

	// 表ID。
	TableId *string `json:"table_id,omitempty"`

	// 表名称。
	TableName *string `json:"table_name,omitempty"`

	// 表别名。
	TableAlias *string `json:"table_alias,omitempty"`

	// 表创建时间。
	CreatedTime *string `json:"created_time,omitempty"`

	// 表更新时间。
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 数据存储位置，分为IoTA和VIEW
	DataLocation *string `json:"data_location,omitempty"`

	// 数据类型，包括“csv”，“parquet”。
	DataType *string `json:"data_type,omitempty"`

	// 数据来源。来源类型有：pipeline, default. 默认为default.
	DataSource *string `json:"data_source,omitempty"`

	// 表类型:IoTA表为MANAGED, View为VIEW
	TableType *string `json:"table_type,omitempty"`

	// 表的描述信息。
	Description *string `json:"description,omitempty"`

	// 分区字段。只有OBS分区表有该参数，其他表没有该参数。
	PartitionColumns *[]string `json:"partition_columns,omitempty"`

	// 仅当数据来源为pipeline时返回。Data Store ID.
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 标签。
	Tags *string `json:"tags,omitempty"`
}

func (Table) String 

func (o Table) String() string

type Tag 

type Tag struct {

	// 标签名称
	Name *string `json:"name,omitempty"`

	// 标签描述
	Description *string `json:"description,omitempty"`
}

func (Tag) String 

func (o Tag) String() string

type TagInfoDto 

type TagInfoDto struct {

	// 算子Id
	OperatorId *string `json:"operator_id,omitempty"`

	// 存储ID
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 标签信息
	Tag *string `json:"tag,omitempty"`
}

标签信息

func (TagInfoDto) String 

func (o TagInfoDto) String() string

type TimeSpan 

type TimeSpan struct {

	// 起始时间
	From string `json:"from"`

	// 结束时间
	To string `json:"to"`
}

起止时间范围

func (TimeSpan) String 

func (o TimeSpan) String() string

type TimeSpanDt 

type TimeSpanDt struct {

	// 起始时间, 使用UTC时间，格式：yyyy-MM-dd'T'HH:mm:ss.SSS'Z',示例：2021-02-01T00:00:00.123Z
	From *string `json:"from,omitempty"`

	// 结束时间，使用UTC时间，格式：yyyy-MM-dd'T'HH:mm:ss.SSS'Z',示例：2021-02-01T00:00:00.123Z
	To *string `json:"to,omitempty"`
}

起止时间

func (TimeSpanDt) String 

func (o TimeSpanDt) String() string

type TransformMetric 

type TransformMetric struct {

	// 声明属性作为表达式参数
	Inputs []InputParam `json:"inputs"`

	// 指标名称
	MetricName string `json:"metric_name"`

	// 表达式
	Expression string `json:"expression"`
}

查询指标

func (TransformMetric) String 

func (o TransformMetric) String() string

type TransformMetrics 

type TransformMetrics struct {
	TimeSpan *TimeSpan `json:"time_span"`

	// 对property按指定tags标签进行过滤查询，填入设备标签与标签值，不可为空，例如 {\"deviceId\": \"id0001\"}
	Tags map[string]string `json:"tags"`

	// 查询的测量指标列表
	Metrics []TransformMetric `json:"metrics"`

	// 返回值个数限制
	Limit *int32 `json:"limit,omitempty"`
}

转换计算定义

func (TransformMetrics) String 

func (o TransformMetrics) String() string

type TransformMetricsRequest 

type TransformMetricsRequest struct {
	TimeSpan *TimeSpanDt `json:"time_span,omitempty"`

	// 对property按指定tags标签进行过滤查询，填入资产标签属性的属性名与属性值，不可为空，例如 {\"tagPropertyA\": \"id0001\"}；注意，标签过滤只对打上标签时刻之后的数据生效，打标签之前的数据不能通过标签过滤
	Tags map[string]interface{} `json:"tags,omitempty"`

	// 属性过滤器，最多5个
	PropertyFilter *[]PropertyFilter `json:"property_filter,omitempty"`

	// 转换查询指标列表，对资产属性进行转换查询得到指标
	Metrics []DtTransformMetrics `json:"metrics"`

	// 返回值个数限制，最多2000个
	Limit *int32 `json:"limit,omitempty"`
}

查询经过转换计算的序列值定义

func (TransformMetricsRequest) String 

func (o TransformMetricsRequest) String() string

type TransformModel 

type TransformModel struct {

	// 输入参数，最多支持10个
	Inputs []InputModel `json:"inputs"`

	Expression *Formula `json:"expression"`

	// 输出属性名(分析任务单输出场景，配合expression的formula使用)
	OutputProperty *string `json:"output_property,omitempty"`

	// 输出属性，最多支持10个
	Outputs *[]OutputWithModel `json:"outputs,omitempty"`
}

转换计算

func (TransformModel) String 

func (o TransformModel) String() string

type TransformResponse 

type TransformResponse struct {

	// 输入参数
	Inputs *[]InputResponse `json:"inputs,omitempty"`

	Expression *Formula `json:"expression,omitempty"`

	// 输出属性名(不推荐使用，待废弃，使用outputs替代)
	OutputProperty *string `json:"output_property,omitempty"`

	Outputs *[]OutputResponse `json:"outputs,omitempty"`
}

转换计算

func (TransformResponse) String 

func (o TransformResponse) String() string

type UpdateAssetModelRequest 

type UpdateAssetModelRequest struct {

	// 模型ID
	ModelId string `json:"model_id"`

	Body *AssetModelModRequest `json:"body,omitempty"`
}

Request Object

func (UpdateAssetModelRequest) String 

func (o UpdateAssetModelRequest) String() string

type UpdateAssetModelResponse 

type UpdateAssetModelResponse struct {

	// 模型ID
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 模型名称
	Name *string `json:"name,omitempty"`

	// 模型显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集
	Properties *[]PropertyModelResponse `json:"properties,omitempty"`

	// 分析任务集
	Analyses *[]AnalysisModelResponse `json:"analyses,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateAssetModelResponse) String 

func (o UpdateAssetModelResponse) String() string

type UpdateAssetNewRequest 

type UpdateAssetNewRequest struct {

	// 资产ID
	AssetId string `json:"asset_id"`

	Body *AssetModRequest `json:"body,omitempty"`
}

Request Object

func (UpdateAssetNewRequest) String 

func (o UpdateAssetNewRequest) String() string

type UpdateAssetNewResponse 

type UpdateAssetNewResponse struct {

	// 资产ID
	AssetId *string `json:"asset_id,omitempty"`

	// 资产模型ID
	AssetModelId *string `json:"asset_model_id,omitempty"`

	// 资产模型名称
	AssetModelName *string `json:"asset_model_name,omitempty"`

	// 资产名称
	Name *string `json:"name,omitempty"`

	// 资产显示名称
	DisplayName *string `json:"display_name,omitempty"`

	// 属性集
	Properties *[]PropertyResponse `json:"properties,omitempty"`

	// 分析任务集
	Analyses *[]AnalysisResponse `json:"analyses,omitempty"`

	// 根资产ID
	Root *string `json:"root,omitempty"`

	// 父资产ID，根资产的父资产ID为null
	Parent *string `json:"parent,omitempty"`

	// 子资产ID集
	Children *[]string `json:"children,omitempty"`

	// 资产状态，正常状态（ACTIVE），异常状态（INACTIVE）；只有草稿态（SKETCH）资产有此状态；资产处于异常状态的场景有：1、该资产存在未填写设备ID的测量数据类别的属性；2、该资产存在未填写静态值的静态配置类别的属性；3、该资产存在分析任务，该分析任务的输入参数存在属性引用类型为引用其他资产属性，且没有为该输入参数配置引用的其他资产的资产ID
	State *string `json:"state,omitempty"`

	// 资产发布状态，发布中（PUBLISHING），发布完成（PUBLISHED）；只能对草稿态（SKETCH）的根资产进行发布，也只有草稿态的根资产有此字段；如果根资产从未发布过则值为null
	PublishState *string `json:"publish_state,omitempty"`

	// 创建时间，格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间，格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 发布时间，只能对草稿态（SKETCH）的根资产进行发布，也只有草稿态的根资产有此字段；如果从未发布过则值为null；格式\"yyyy-MM-dd'T'HH:mm:ss'Z'\"
	PublishedTime  *string `json:"published_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateAssetNewResponse) String 

func (o UpdateAssetNewResponse) String() string

type UpdateBatchJobRequest 

type UpdateBatchJobRequest struct {

	// 数据开发任务ID。
	JobId string `json:"job_id"`

	Body *Job `json:"body,omitempty"`
}

Request Object

func (UpdateBatchJobRequest) String 

func (o UpdateBatchJobRequest) String() string

type UpdateBatchJobResponse 

type UpdateBatchJobResponse struct {

	// 仅在响应返回。作业ID。
	JobId *string `json:"job_id,omitempty"`

	// 作业名称。只能包含数字、英文字母、中文字母、下划线以及中划线。长度为1~128。
	JobName *string `json:"job_name,omitempty"`

	// 标签。只能包含数字、英文字母、中文字符、下划线、中划线、逗号以及斜杠。长度为0~128。
	Tags *string `json:"tags,omitempty"`

	// 仅在响应返回。创建时间。
	CreatedTime *string `json:"created_time,omitempty"`

	// 仅在响应返回。更新时间。
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 作业类型。目前仅支持SqlJob.
	JobType *string `json:"job_type,omitempty"`

	// 作业查询结果导出到OBS的路径。覆写已存在文件。
	ExportPath *string `json:"export_path,omitempty"`

	// 导出文件时是否合并结果文件。true：合并成一个结果文件；false：不合并结果文件。
	MergeResultFile *bool `json:"merge_result_file,omitempty"`

	SqlJob *SqlJob `json:"sql_job,omitempty"`

	Schedule       *Schedule `json:"schedule,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (UpdateBatchJobResponse) String 

func (o UpdateBatchJobResponse) String() string

type UpdateDataSourceRequest 

type UpdateDataSourceRequest struct {

	// 数据源id
	DatasourceId string `json:"datasource_id"`

	Body *UpdateDatasourceReqDto `json:"body,omitempty"`
}

Request Object

func (UpdateDataSourceRequest) String 

func (o UpdateDataSourceRequest) String() string

type UpdateDataSourceResponse 

type UpdateDataSourceResponse struct {

	// 数据源id
	Id *string `json:"id,omitempty"`

	// 数据源名称
	Name *string `json:"name,omitempty"`

	// 数据源类型, 包括：IOTDA、API[、OBS、DIS、SMN、FUNCTION_GRAPH、MODEL_ARTS、DCS、KAFKA](tag:IoTA-Cloud-Only)、NODE。数据源不支持修改类型。
	Type *string `json:"type,omitempty"`

	Content *ContentDetailRsp `json:"content,omitempty"`

	// 创建时间，格式为：yyyy-MM-dd'T'HH:mm:ss'Z'
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间，格式为：yyyy-MM-dd'T'HH:mm:ss'Z'
	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateDataSourceResponse) String 

func (o UpdateDataSourceResponse) String() string

type UpdateDataStore 

type UpdateDataStore struct {

	// 存储名称
	Name *string `json:"name,omitempty"`

	// 标签，更新存储时标签只可新增，不可修改或删除原有标签
	Tags *[]Tag `json:"tags,omitempty"`

	// 指标
	Metrics *[]Metric `json:"metrics,omitempty"`

	// 属性，更新存储时属性只可新增，不可修改或删除原有属性
	Properties *[]Property `json:"properties,omitempty"`
}

func (UpdateDataStore) String 

func (o UpdateDataStore) String() string

type UpdateDataStoreRequest 

type UpdateDataStoreRequest struct {

	// 存储 ID
	DataStoreId string `json:"data_store_id"`

	Body *UpdateDataStore `json:"body,omitempty"`
}

Request Object

func (UpdateDataStoreRequest) String 

func (o UpdateDataStoreRequest) String() string

type UpdateDataStoreResponse 

type UpdateDataStoreResponse struct {

	// 存储 ID
	DataStoreId *string `json:"data_store_id,omitempty"`

	// 存储名称
	Name *string `json:"name,omitempty"`

	// 存储 ID
	GroupId *string `json:"group_id,omitempty"`

	// 标签
	Tags *[]Tag `json:"tags,omitempty"`

	// 指标
	Metrics *[]Metric `json:"metrics,omitempty"`

	// 属性
	Properties *[]Property `json:"properties,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateDataStoreResponse) String 

func (o UpdateDataStoreResponse) String() string

type UpdateDatasourceReqDto 

type UpdateDatasourceReqDto struct {

	// 数据源名称
	Name string `json:"name"`

	// 数据源类型, 包括：IOTDA、API[、OBS、DIS、SMN、FUNCTION_GRAPH、MODEL_ARTS、DCS、KAFKA](tag:IoTA-Cloud-Only)、NODE。数据源不支持修改类型。
	Type string `json:"type"`

	Content *ContentDetailReq `json:"content,omitempty"`
}

func (UpdateDatasourceReqDto) String 

func (o UpdateDatasourceReqDto) String() string

type UpdateGroupRequest 

type UpdateGroupRequest struct {

	// 存储组 ID
	GroupId string `json:"group_id"`

	Body *StorageGroup `json:"body,omitempty"`
}

Request Object

func (UpdateGroupRequest) String 

func (o UpdateGroupRequest) String() string

type UpdateGroupResponse 

type UpdateGroupResponse struct {

	// 存储组 ID
	GroupId *string `json:"group_id,omitempty"`

	// 存储组名称
	Name *string `json:"name,omitempty"`

	// 描述
	Description *string `json:"description,omitempty"`

	// 温数据存储用量
	WarmDataUsage *int64 `json:"warm_data_usage,omitempty"`

	// 此存储组下存储实例的个数
	DataStoreCount *int64 `json:"data_store_count,omitempty"`

	// 冷数据存储用量
	ColdDataUsage *int64 `json:"cold_data_usage,omitempty"`

	// 温数据老化策略，单位只支持d（天），且只支持整数，如365天则可配置为“365d”，如“365h”或“360.5d”等均不被支持
	WarmDataRetentionPolicy *string `json:"warm_data_retention_policy,omitempty"`

	// 冷数据老化策略，单位只支持d（天），且只支持整数，如365天则可配置为“365d”，如“365h”或“360.5d”等均不被支持
	ColdDataRetentionPolicy *string `json:"cold_data_retention_policy,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 修改时间
	ModifiedTime *string `json:"modified_time,omitempty"`

	// 存储类型，有资产存储(取值:AssetStorage)、设备存储(取值:DeviceStorage)两种类型
	Type           *string `json:"type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateGroupResponse) String 

func (o UpdateGroupResponse) String() string

type UpdatePipelineJobRequest 

type UpdatePipelineJobRequest struct {

	// 是否需要校验配置是否正确
	Check *bool `json:"check,omitempty"`

	// 管道ID
	PipelineId string `json:"pipeline_id"`

	// 管道作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：数据管道算子配置指南。
	Body map[string]interface{} `json:"body,omitempty"`
}

Request Object

func (UpdatePipelineJobRequest) String 

func (o UpdatePipelineJobRequest) String() string

type UpdatePipelineJobResponse 

type UpdatePipelineJobResponse struct {

	// 管道ID
	PipelineId *string `json:"pipeline_id,omitempty"`

	// 管道状态
	PipelineState *string `json:"pipeline_state,omitempty"`

	// 操作结果
	Status *string `json:"status,omitempty"`

	// 管道错误详情
	CheckInfo      map[string]interface{} `json:"check_info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (UpdatePipelineJobResponse) String 

func (o UpdatePipelineJobResponse) String() string

type UpdateStreamingJobRequest 

type UpdateStreamingJobRequest struct {

	// 是否需要校验配置是否正确
	Check *bool `json:"check,omitempty"`

	// 作业ID
	JobId string `json:"job_id"`

	// 实时分析作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：实时分析算子配置指南。
	Body map[string]interface{} `json:"body,omitempty"`
}

Request Object

func (UpdateStreamingJobRequest) String 

func (o UpdateStreamingJobRequest) String() string

type UpdateStreamingJobResponse 

type UpdateStreamingJobResponse struct {

	// 作业ID
	JobId *string `json:"job_id,omitempty"`

	// 作业状态
	JobState *string `json:"job_state,omitempty"`

	// 操作结果
	Status *string `json:"status,omitempty"`

	// 作业错误详情
	CheckInfo      map[string]interface{} `json:"check_info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (UpdateStreamingJobResponse) String 

func (o UpdateStreamingJobResponse) String() string

type ValidateSqlRequest 

type ValidateSqlRequest struct {
	Body *ValidateSqlRequestBody `json:"body,omitempty"`
}

Request Object

func (ValidateSqlRequest) String 

func (o ValidateSqlRequest) String() string

type ValidateSqlRequestBody 

type ValidateSqlRequestBody struct {

	// 待执行的SQL语句。
	Sql *string `json:"sql,omitempty"`
}

func (ValidateSqlRequestBody) String 

func (o ValidateSqlRequestBody) String() string

type ValidateSqlResponse 

type ValidateSqlResponse struct {

	// SQL是否通过语法校验
	Valid          *bool `json:"valid,omitempty"`
	HttpStatusCode int   `json:"-"`
}

Response Object

func (ValidateSqlResponse) String 

func (o ValidateSqlResponse) String() string

type VpcepInfo 

type VpcepInfo struct {

	// Kafka的Broker ip
	KafkaBrokerIp string `json:"kafka_broker_ip"`

	// Kafka的VPCEP的service id
	VpcepServiceId string `json:"vpcep_service_id"`

	// Kafka的VPCEP的service name
	VpcepServiceName string `json:"vpcep_service_name"`

	// Kafka的VPCEP的client port
	VpcepClientPort int32 `json:"vpcep_client_port"`
}

VPCEP信息

func (VpcepInfo) String 

func (o VpcepInfo) String() string

type VpcepInfoRsp 

type VpcepInfoRsp struct {

	// Kafka的VPCEP的service id
	VpcepServiceId string `json:"vpcep_service_id"`

	// Kafka的VPCEP的service name
	VpcepServiceName string `json:"vpcep_service_name"`

	// Kafka的VPCEP的client ip
	VpcepClientIp *string `json:"vpcep_client_ip,omitempty"`

	// Kafka的VPCEP的client port
	VpcepClientPort int32 `json:"vpcep_client_port"`

	// Kafka的Broker ip
	KafkaBrokerIp string `json:"kafka_broker_ip"`
}

VPCEP信息

func (VpcepInfoRsp) String 

func (o VpcepInfoRsp) String() string

Source Files

View all Source files

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.