检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
连接外部Kafka AstroZero支持从平台内部Kafka或外部Kafka采集数据，从内部Kafka采集的数据不能再输出到内部Kafka中。 勾选：表示从外部Kafka采集数据。 不勾选：表示从平台内部Kafka采集数据。 Kafka集群地址 勾选“连接外部Kafka”时，才
AstroZero的数据连接可以分为以下几类： 消息类的数据 通过AstroZero提供的数据接入能力，从外部数据源（如ROMA的MQS、Kafka、设备接入IoTDA等）获取数据，详情请参见如何配置数据接入。 接口类的数据 通过AstroZero提供的Rest服务、SOAP服务或脚
OAuth鉴权模式 使用说明 使用OAuth客户端模式鉴权，AstroZero会根据填写的OAuth服务端地址、Client ID和Client Secret，在发送请求前，后台自动获取第三方服务端的access_token， 并在发送请求时携带此access_token，服务端
鉴权协议：设置鉴权协议，支持OAuth、简单消息头和JWT（JSON Web Tokens）三种。 鉴权模式：设置为“client credentials”，此处只支持OAuth2的client credentials鉴权模式。 鉴权地址：第三方系统OAuth2协议，获取的token地址。例如，
AstroZero支持从平台内部Kafka或者外部Kafka采集数据，从内部Kafka采集的数据不能再输出到内部Kafka中。勾选该项，表示从外部Kafka采集数据，则需要配置“Kafka集群地址”和“订阅主题”。 默认不勾选，表示从平台内部Kafka采集数据。 Kafka集群地址 当勾选“连接外
授权模式，对应OAuth2.0中的grant_type字段的值。 配置为client_credentials，即客户端模式。 client_id String M Body 鉴权的客户端ID。 配置为7中获取的值。 client_secret String M Body 鉴权密钥。 配置为7中获取的值。
(exist) { client.dropIndex(indexName1) } exist = client.checkIndexExist(indexName2) if (exist) { client.dropIndex(indexName2) } client.createIndex(indexName1)
roZero相连的Kafka。 Kafka集群地址：数据源Kafka的集群地址。多个节点服务器地址可用“,”间隔，格式为“Kafka节点1的ip:节点1端口号,Kafka节点2的ip:节点2端口号,...”。 获取Kafka的IP和端口号方法：登录每台Kafka节点服务器，查看“
Connect获取数据时，需要对数据进行一系列处理后，才能转化成内部事件。通过修改图1中的“Kafka集群地址”，可实现对接ROMA Connect的MQS，参数说明请参见表1。 图1 编辑Kafka 表1 对接MQS参数说明 参数 说明 Kafka集群地址 配置为ROMA Connect MQS的地址，多个之间用“
分区字段：从事件中，选择一个自定义参数，用作Kafka的分区字段。设置后，会根据该字段值进行路由，相同的值将路由到同一个Kafka分区。如果不指定，则默认随机路由到不同Kafka分区，从而提升并发处理性能。 发送到外部：系统内部有配置与AstroZero相连Kafka的固定Topic（__BINGO_SYS_TOPIC）。
(exist) { client.dropIndex(indexName1) } exist = client.checkIndexExist(indexName2) if (exist) { client.dropIndex(indexName2) } client.createIndex(indexName1)
授权模式，对应OAuth2.0中的grant_type字段的值。 配置为client_credentials，即客户端模式。 client_id String M Body 鉴权的客户端ID。 配置为5中获取的值。 client_secret String M Body 鉴权密钥。 配置为5中获取的值。
在OAuth管理列表页，单击具体OAuth所在行，下载密钥文件到本地，从中获取客户端鉴权ID“client_id”取值。 client_secret String M Body 客户端密钥。 参考client_id，获取客户端鉴权密钥“client_secret”取值。 redirect_url String O
授权模式，OAuth2.0中的grant_type字段的取值。 client_credentials（即客户端模式） client_id String M Body 鉴权的客户端ID，可在OAuth查看。 从上一步骤获取。 client_secret String M Body 鉴权密钥，可在OAuth查看。
as connector from "connector"; let client = connector.newClient("LT927__test", "test1"); let result = client.invoke("LT927__flapRefund", {}); console
授权模式，对应OAuth2.0中的grant_type字段的值。 配置为client_credentials，即客户端模式。 client_id String M Body 鉴权的客户端ID。 配置为5中获取的值。 client_secret String M Body 鉴权密钥。 配置为5中获取的值。
参数说明 事件 选择待发送的事件。 分区字段 从事件中选择一个自定义参数用作Kafka的分区字段，则根据该字段值进行路由，相同的值将路由到同一个Kafka分区；如果不指定，则默认随机路由到不同Kafka分区，从而提升并发处理性能。 须知： 建议选择有区分度的关键字段，该字段必须是事件的自定义字段。
选择待发送的事件，直接在下拉框中选择。 分区字段 从事件中选择一个自定义参数用作Kafka的分区字段，则根据该字段值进行路由，相同的值将路由到同一个Kafka分区；如果不指定，则默认随机路由到不同Kafka分区，从而提升并发处理性能。 须知： 建议选择有区分度的关键字段，该字段必须是事件的自定义字段。
从事件中，选择一个自定义参数，用作Kafka的分区字段。设置后，会根据该字段值进行路由，相同的值将路由到同一个Kafka分区。如果不指定，则默认随机路由到不同Kafka分区，从而提升并发处理性能。 发送到外部 系统内部有配置与AstroZero相连Kafka的固定Topic（__BINGO_SYS_TOPIC）。
（其他代码） const client = bp.newInstanceClient(); client.start(BPM名称, BPM版本号, BPM中定义的变量); 脚本样例如下： import * as bp from 'bp'; let client = bp.newInstanceClient();
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
