REST Resource: projects.locations.clusters.analyses

资源:分析

用于描述“Analysis”对象的消息。

JSON 表示法
{
  "name": string,
  "createTime": string,
  "updateTime": string,
  "labels": {
    string: string,
    ...
  },
  "analysisDefinition": {
    object (AnalysisDefinition)
  },
  "inputStreamsMapping": {
    string: string,
    ...
  },
  "outputStreamsMapping": {
    string: string,
    ...
  },
  "disableEventWatch": boolean
}
字段
name

string

资源的名称。

createTime

string (Timestamp format)

仅限输出。创建时间戳。

时间戳采用 RFC3339 世界协调时间(UTC,即“祖鲁时”)格式,精确到纳秒,最多九个小数位。示例:"2014-10-02T15:01:23Z""2014-10-02T15:01:23.045123456Z"

updateTime

string (Timestamp format)

仅限输出。更新时间戳。

时间戳采用 RFC3339 世界协调时间(UTC,即“祖鲁时”)格式,精确到纳秒,最多九个小数位。示例:"2014-10-02T15:01:23Z""2014-10-02T15:01:23.045123456Z"

labels

map (key: string, value: string)

标签以键值对的形式提供。

包含一系列 "key": value 对的对象。示例:{ "name": "wrench", "mass": "1.3kg", "count": "3" }

analysisDefinition

object (AnalysisDefinition)

分析的定义。

inputStreamsMapping

map (key: string, value: string)

将定义中的输入参数映射到实际数据流。例如,假设您有一个名为“input-0”的流源操作符,并且您尝试从真实流“stream-0”接收数据。您可以添加以下映射:[input-0: stream-0]。

包含一系列 "key": value 对的对象。示例:{ "name": "wrench", "mass": "1.3kg", "count": "3" }

outputStreamsMapping

map (key: string, value: string)

将定义中的输出参数映射到实际数据流。例如,假设您有一个名为“output-0”的流接收器运算符,并尝试发送到实际流“stream-0”。您可以添加以下映射:[output-0: stream-0]。

包含一系列 "key": value 对的对象。示例:{ "name": "wrench", "mass": "1.3kg", "count": "3" }

disableEventWatch

boolean

布尔标志,用于指示您是否要停用在输入流中发生新事件时自动启动进程的功能。如果您想手动启动流程,则需要将此字段设为 true。

AnalysisDefinition

定义完整的分析。

下面介绍了整个实时分析流水线。您可以将其视为多图的边列表表示法。

此数据可以由人直接以 protobuf 文本格式编写,也可以由编程 API(可能是 Python 或 JavaScript,具体取决于上下文)生成。

JSON 表示法
{
  "analyzers": [
    {
      object (AnalyzerDefinition)
    }
  ]
}
字段
analyzers[]

object (AnalyzerDefinition)

分析器定义。

AnalyzerDefinition

定义分析器。

分析器使用其所代表的运算符中定义的逻辑处理其输入数据流中的数据。当然,它会为运算符中声明的输出流生成数据。

JSON 表示法
{
  "analyzer": string,
  "operator": string,
  "inputs": [
    {
      object (StreamInput)
    }
  ],
  "attrs": {
    string: {
      object (AttributeValue)
    },
    ...
  },
  "debugOptions": {
    object (DebugOptions)
  }
}
字段
analyzer

string

此分析器的名称。

暂定为 [a-z][a-z0-9]*(_[a-z0-9]+)*。

operator

string

此分析器运行的运算符的名称。

必须与受支持的运营商的名称匹配。

inputs[]

object (StreamInput)

输入流。

attrs

map (key: string, value: object (AttributeValue))

此分析器应用于运算符的属性值。

提供属性名称与您要应用的实际值之间的映射。如果省略属性名称,则系统会采用预配置的默认值。

包含一系列 "key": value 对的对象。示例:{ "name": "wrench", "mass": "1.3kg", "count": "3" }

debugOptions

object (DebugOptions)

调试选项。

StreamInput

此分析器的输入。

我们接受以下格式的输入名称引用::

示例:

假设您有一个名为“SomeOp”的运算符,它有 2 个输出参数,第一个参数名为“foo”,第二个参数名为“bar”,还有一个名为“MyOp”的运算符,它接受 2 个输入。

此外,假设有一个名为“some-analyzer”的分析器正在运行“SomeOp”,另一个名为“my-analyzer”的分析器正在运行“MyOp”。

如需指明“my-analyzer”将使用“some-analyzer”的“foo”输出作为其第一个输入,并将“some-analyzer”的“bar”输出作为其第二个输入,您可以将此字段设置为以下内容:input = ["some-analyzer:foo", "some-analyzer:bar"]

JSON 表示法
{
  "input": string
}
字段
input

string

数据流输入的名称(如上所述)。

DebugOptions

这些选项仅用于调试目的。

JSON 表示法
{
  "environmentVariables": {
    string: string,
    ...
  }
}
字段
environmentVariables

map (key: string, value: string)

环境变量。

包含一系列 "key": value 对的对象。示例:{ "name": "wrench", "mass": "1.3kg", "count": "3" }

方法

create

在给定的项目和位置中创建新的分析。

delete

删除单个分析。

get

获取单个分析的详细信息。

list

列出给定项目和位置中的分析。

patch

更新单个分析的参数。