GetEventStreaming - EventBridge: Central de Documentação do Alibaba Cloud

Obtém os detalhes de um fluxo de eventos.

Descrição da operação

Obtém os detalhes de um fluxo de eventos.

Experimente agora

Experimente esta API no OpenAPI Explorer, sem necessidade de assinatura manual. Chamadas bem-sucedidas geram automaticamente código SDK correspondente aos seus parâmetros. Faça o download com segurança de credenciais integrada para uso local.

Testar

Autorização RAM

A tabela abaixo descreve a autorização necessária para chamar esta API. Você pode defini-la em uma política do Resource Access Management (RAM). As colunas da tabela estão detalhadas abaixo:

Ação: As ações que podem ser usadas no elemento Action das instruções de política de permissão do RAM para conceder permissões para executar a operação.
API: A API que você pode chamar para executar a ação.
Nível de acesso: O nível de acesso predefinido concedido para cada API. Valores válidos: create, list, get, update e delete.
Tipo de recurso: O tipo de recurso que suporta autorização para executar a ação. Indica se a ação suporta permissão em nível de recurso. O recurso especificado deve ser compatível com a ação. Caso contrário, a política será ineficaz.
- Para APIs com permissões em nível de recurso, os tipos de recursos obrigatórios são marcados com um asterisco (*). Especifique o Nome de Recurso Alibaba Cloud (ARN) correspondente no elemento Resource da política.
- Para APIs sem permissões em nível de recurso, é exibido como Todos os Recursos. Use um asterisco (*) no elemento Resource da política.
Chave de condição: As chaves de condição definidas pelo serviço. A chave permite controle granular, aplicando-se somente a ações ou a ações associadas a recursos específicos. Além das chaves de condição específicas do serviço, o Alibaba Cloud fornece um conjunto de chaves de condição comuns aplicáveis a todos os serviços compatíveis com RAM.
Ação dependente: As ações dependentes necessárias para executar a ação. Para concluir a ação, o usuário RAM ou a função RAM deve ter permissões para executar todas as ações dependentes.

Ação

Nível de acesso

Tipo de recurso

Chave de condição

Ação dependente

eventbridge:GetEventStreaming

get

*EventStreaming

acs:eventbridge:{#regionId}:{#accountId}:eventstreaming/{#EventStreamingName}

Nenhuma

Parâmetros da solicitação

Parâmetro	Tipo	Obrigatório	Descrição	Exemplo
EventStreamingName	string	Sim	O nome do fluxo de eventos a ser consultado.	myeventstreaming

Elementos de resposta

Elemento	Tipo	Descrição	Exemplo
	object	Os parâmetros de resposta.
Message	string	A mensagem de erro.	The event streaming [xxxx] not existed!
RequestId	string	O ID da solicitação gerado pelo Alibaba Cloud para esta solicitação.	7892F480-58C9-5067-AB35-8A7BEF****
Data	object	Os dados retornados.
EventStreamingName	string	O nome do fluxo de eventos.	rocketmq-sync
Description	string	A descrição do fluxo de eventos.	RocketMQ-to-RocketMQ
Source	object	A origem do evento.
SourceMNSParameters	object	Os parâmetros para a origem Simple Message Queue (anteriormente MNS).
RegionId	string	O ID da região.	cn-hangzhou
QueueName	string	O nome da fila Simple Message Queue (anteriormente MNS).	demo
IsBase64Decode	boolean	Indica se a decodificação Base64 está ativada.	true
SourceRabbitMQParameters	object	Os parâmetros para a origem RabbitMQ.
RegionId	string	O ID da região.	cn-hangzhou
InstanceId	string	O ID da instância ApsaraMQ for RabbitMQ.	i-f8z9a9mcgwri1c1i****
VirtualHostName	string	O nome do vhost na instância ApsaraMQ for RabbitMQ.	eb-connect
QueueName	string	O nome da fila na instância ApsaraMQ for RabbitMQ.	comp
SourceRocketMQParameters	object	Os parâmetros para a origem RocketMQ.
RegionId	string	O ID da região da instância ApsaraMQ for RocketMQ.	cn-hangzhou
InstanceId	string	O ID da instância ApsaraMQ for RocketMQ.	i-f8zbher64dlm58pl****
Topic	string	O tópico da mensagem.	topic_add_anima
Tag	string	A tag de filtro da mensagem.	v1
Offset	string	O offset de consumo da mensagem. Valores válidos: CONSUME_FROM_LAST_OFFSET: O consumo inicia a partir do offset mais recente. CONSUME_FROM_FIRST_OFFSET: O consumo inicia a partir do offset mais antigo. CONSUME_FROM_TIMESTAMP: O consumo inicia a partir do offset em um ponto no tempo especificado.	CONSUMEFROMLASTOFFSET
GroupID	string	O ID do grupo da instância ApsaraMQ for RocketMQ.	GID_group1
Timestamp	integer	O timestamp. Este parâmetro é válido somente quando o parâmetro Offset está definido como CONSUME_FROM_TIMESTAMP.	1636597951964
InstanceType	string	O tipo de instância. Valores válidos: Cloud_4: instância ApsaraMQ for RocketMQ 4.0 (padrão) Cloud_5: instância ApsaraMQ for RocketMQ 5.0 SelfBuilt: cluster Apache RocketMQ autogerenciado	Cloud_4
InstanceEndpoint	string	O endpoint da instância.	reg****-vpc.cn-zhangjiakou.aliyuncs.com
AuthType	string	O tipo de autenticação.	ACL
InstanceUsername	string	O nome de usuário da instância.	xxxa
InstancePassword	string	A senha da instância.	xxxa
InstanceVpcId	string	O ID da VPC da instância.	vpc-m5e3sv4b12345****
InstanceVSwitchIds	string	Os IDs de vSwitch da instância.	vsw-m5ev8asdc6h12****
InstanceSecurityGroupId	string	O ID do grupo de segurança da instância.	sg-m5edtu24f12345****
InstanceNetwork	string	O tipo de rede da instância. Valores válidos: PublicNetwork PrivateNetwork	PublicNetwork
BodyDataType	string	O formato de codificação da mensagem. Valores válidos: Json Text Binary	Json
FilterType	string	O tipo de filtro de mensagem.	Tag
FilterSql	string	A instrução de filtro SQL.	index > 10
VpcId	string	O ID da VPC.	vpc-m5e3sv4b12345****
VSwitchIds	string	O ID do vSwitch.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	O ID do grupo de segurança.	sg-m5edtu24f12345****
Network	string	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork	PublicNetwork
SourceRocketMQCheckpointParameters	object	Os parâmetros para a origem de checkpoint RocketMQ.
RegionId	string	O ID da região.	cn-hangzhou
InstanceType	string	O tipo de instância. Valores válidos: Cloud_4: instância ApsaraMQ for RocketMQ 4.0 (padrão) Cloud_5: instância ApsaraMQ for RocketMQ 5.0 SelfBuilt: cluster Apache RocketMQ autogerenciado	Cloud_4
InstanceId	string	O ID da instância.	rmp-cn-jte3w******
Topics	array	Os tópicos de mensagem.
	string	Os tópicos de mensagem.	opic_add_anima
SourceApacheRocketMQCheckpointParameters	object	Os parâmetros para a origem de checkpoint RocketMQ.
RegionId	string	O ID da região.	cn-hangzhou
InstanceId	string	O ID da instância RocketMQ.	MQ_INST_164901546557**_BAAN**
Topics	array	A lista de tópicos.
	string	A lista de tópicos a serem consumidos.	["Topic_1","Topic_2"]
InstanceEndpoint	string	O endpoint da instância.	registry-vpc.cn-hangzhou.aliyuncs.com
InstanceUsername	string	O nome de usuário da instância.	admin
InstancePassword	string	A senha da instância.	123456
NetworkType	string	O tipo de rede.	PrivateNetwork
VpcId	string	O ID da VPC.	vpc-adw1awdw*****
VSwitchId	string	O ID do vSwitch.	vsw-dwaafds****
SecurityGroupId	string	O ID do grupo de segurança.	sg-mw43*****
SourceKafkaParameters	object	Os parâmetros para a origem Kafka.
RegionId	string	O ID da região da instância.	cn-hangzhou
InstanceId	string	O ID da instância.	i-bp1fbtrnqmjvgq66****
Topic	string	O nome do tópico.	topic_empower_1642473600414
ConsumerGroup	string	O ID do grupo do consumidor que assina o tópico.	GID_TEST
OffsetReset	string	O offset.	latest
Network	string	A configuração de rede. Valor padrão: Default. Defina este parâmetro como PublicNetwork para redes VPC.	Default
VpcId	string	O ID da VPC.	vpc-2zehizpoendb3****
VSwitchIds	string	O ID do vSwitch.	vsw-wz9qqeovkwjxlu9uc****
SecurityGroupId	string	O ID do grupo de segurança.	sg-2vcgdxz7o1n9zapp****
ValueDataType	string	O formato de codificação e decodificação. Valores válidos: JSON: Os bytes são decodificados para uma string usando codificação UTF-8 e, em seguida, analisados como JSON. Text: Os bytes são decodificados para uma string usando codificação UTF-8 e colocados diretamente no payload. Binary: Os bytes são codificados para uma string usando codificação Base64 e colocados no payload.	Text
SourceMQTTParameters	object	Os parâmetros para a origem MQTT.
RegionId	string	O ID da região.	cn-shanghai
InstanceId	string	O ID da instância.	i-2ze06wqdwk0uq14k****
Topic	string	O nome do tópico.	TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel
BodyDataType	string	O formato de codificação da mensagem. Valores válidos: JSON Text Binary	JSON
NetworkType	string	O tipo de rede.
VpcId	string	O ID da VPC.
VSwitchIds	string	O ID do vSwitch.
SecurityGroupId	string	O ID do grupo de segurança.
SourceDTSParameters	object	Os parâmetros para a origem DTS.
TaskId	string	O ID da tarefa.	f86e5814-b223-482c-b768-3b873297****
BrokerUrl	string	O endereço de rede e o número da porta do canal de assinatura de dados.
Topic	string	O tópico de assinatura do canal de assinatura de dados.	TP_TEST_UNDERWRITE_ISSUE
Sid	string	O ID do grupo de consumidores.	HD1
Username	string	A conta do grupo de consumidores.	admin
Password	string	A senha da conta do grupo de consumidores.	admin****
InitCheckPoint	string	O checkpoint de consumo, que é o timestamp quando o cliente SDK consome o primeiro registro de dados. O valor é um timestamp UNIX.	1620962769
SourceSLSParameters	object	Os parâmetros para a origem Simple Log Service (SLS).
Project	string	O projeto do Simple Log Service.	dmmzk
LogStore	string	O Logstore do Simple Log Service.	waf-logstore
ConsumerGroup	string	O grupo de consumidores.
ConsumePosition	string	O offset de consumo inicial. Você pode selecionar o offset mais antigo ou mais recente, que corresponde a "begin" ou "end", respectivamente. Você também pode iniciar o consumo a partir de um ponto no tempo especificado, em segundos.	begin
RoleName	string	O nome da role para autorização. Para autorizar o barramento de eventos EventBridge a usar esta role para ler o conteúdo de logs do SLS, crie uma role no console do Resource Access Management (RAM), selecione "Alibaba Cloud Service" e defina "Trusted Service" como "event bus".	testRole
SourcePrometheusParameters	object	Os parâmetros para a origem de eventos Prometheus.
RegionId	string	O ID da região.	cn-hangzhou
ClusterId	string	O ID do cluster.	c83555068b6******ad213f565f209
DataType	string	O tipo de dados.	Json
Labels	string	Os labels.	__name__=.*
RoleName	string	O nome da role da tarefa.	test-role
ExternalLabels	string	Os labels externos anexados ao fluxo de eventos.	{"env":"test"}
SourceCustomizedKafkaParameters	object	Os parâmetros para a origem de eventos Kafka personalizada.
InstanceId	string	O ID da instância ApsaraMQ for Kafka.	r-8vb64581862c****
SourceCustomizedKafkaConnectorParameters	object	Os parâmetros para a origem de eventos Apache Kafka com conector personalizado.
ConnectorPackageUrl	string	A URL de download do pacote ZIP de recursos do OSS.	"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ"
ConnectorParameters	object	Os parâmetros do conector.
Name	string	O nome do conector.	test-name
Config	object	A configuração do conector.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
WorkerParameters	object	A configuração da instância.	{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }
SourceApacheKafkaParameters	object
Bootstraps	string
Topic	string
ConsumerGroup	string
OffsetReset	string
ValueDataType	string
VpcId	string
VSwitchIds	string
SecurityGroupId	string
NetworkType	string
SecurityProtocol	string
SaslMechanism	string
SaslUser	string
SaslPassword	string
SslTruststoreCertificates	string	[Obrigatório para SSL] O certificado de confiança do servidor Kafka. Usado para autenticar o certificado SSL do Kafka broker e prevenir ataques man-in-the-middle. Formato: codificação Base64 em formato PEM, normalmente contendo o certificado CA ou o certificado do servidor Kafka. Exemplo: codifique em Base64 o conteúdo do arquivo PEM do certificado CA (certifique-se de que o conteúdo comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----'). Se o Kafka usar um certificado autoassinado, forneça o certificado CA que emitiu o certificado.
SslKeystoreCertificateChain	string	[Obrigatório para autenticação mútua] A cadeia de certificados do cliente Kafka. Obrigatório quando o servidor Kafka habilita autenticação SSL mútua (ssl.client.auth=required). Formato: PEM codificado em Base64, contendo o certificado do cliente e a cadeia de certificados completa (certificado do cliente primeiro, certificado CA intermediário em seguida, certificado CA raiz opcional). Nota: certifique-se de que cada conteúdo de arquivo PEM comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----', depois codifique em Base64 o conteúdo concatenado.
SslKeyPassword	string	[Obrigatório para chave privada criptografada] A senha da chave privada do cliente Kafka. Obrigatório quando a chave privada do cliente é criptografada (o arquivo PEM contém marcadores 'Proc-Type: 4,ENCRYPTED' ou 'ENCRYPTED'). Deixe vazio se a chave privada não for criptografada. Nota: esta senha é usada apenas para descriptografar a chave privada e não está relacionada à autenticação do Kafka.
SslKeystoreKey	object	[Obrigatório para autenticação bidirecional] O objeto de configuração da chave privada SSL. Obrigatório quando o servidor Kafka habilita autenticação SSL bidirecional. A chave suporta apenas o padrão KMS: especifique o recurso EPS do Key Management Service (KMS) que armazena a chave privada usando KmsArn. O sistema recupera o conteúdo da chave privada do KMS apenas em memória, o que proporciona maior segurança. Exemplo de configuração: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}
KmsArn	string	[Obrigatório] O ARN do recurso KMS que armazena a chave privada SSL. Usado para localizar a instância KMS que armazena a chave privada do cliente. Exemplo de formato: 'acs:kms:ap-southeast-1:123456789:secret/ssl-keystore-key-xxxx'. Você pode visualizar o ARN da chave correspondente no console do KMS.
KmsSecretValueKey	string	[Modo KV do KMS] O nome da chave no segredo KMS. Quando o segredo KMS é armazenado em uma estrutura de chave-valor (KV), especifique este parâmetro para indicar a chave que corresponde à chave privada SSL. Exemplo: se o segredo KMS for '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', especifique 'ssl_keystore_key'. Deixe este parâmetro vazio se o segredo KMS estiver em modo de texto simples (armazena diretamente o conteúdo PEM da chave privada).
SourceOSSParameters	object	Os parâmetros para a origem de eventos OSS.
RoleName	string	O nome da role que fornece autorização para o barramento de eventos EventBridge ler arquivos OSS. A role deve ter pelo menos permissões somente leitura no OSS.	eventbridge_oss_role
BucketName	string	O nome do bucket OSS.	bucket_abc
Prefix	string	O prefixo do caminho do arquivo.	fun/document/
LoadMode	string	O modo de carregamento de dados. O valor single indica carregamento de documento único, e o valor element indica carregamento em blocos. Valores válidos: single/element. Valor padrão: single.	single
LoadFormat	string	O carregador de documentos.	TextLoader
Delimiter	string	O delimitador. No modo de carregamento em blocos, este delimitador é usado como identificador de segmentação de texto. O delimitador padrão é o caractere de nova linha .	\n
SourceOpenSourceRabbitMQParameters	object	Os parâmetros para a origem RabbitMQ de código aberto.
Endpoint	string	O endpoint da instância RabbitMQ de código aberto.	192.168.1.100:5672
VirtualHostName	string	O nome do vhost na instância RabbitMQ de código aberto.	eb-connect
QueueName	string	O nome da fila na instância RabbitMQ de código aberto.	demo
BodyDataType	string	O formato de codificação da mensagem. Valores válidos: JSON Text Binary	Json
Username	string	O nome de usuário.	admin
Password	string	A senha.	******
VpcId	string	O ID da VPC.	vpc-bp1vllc1lnw1v657******
VSwitchIds	string	O ID do vSwitch.	vsw-uf65zhil5oukof5******
SecurityGroupId	string	O ID do grupo de segurança.	sg-2ze65razphjfz3******
NetworkType	string	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork	PrivateNetwork
AuthType	string	O tipo de autenticação.	ACL
SourceEventBusParameters	object	Os parâmetros para a origem do barramento de eventos.
EventBusName	string	O nome do barramento de eventos.	demo
EventRuleName	string	O nome da regra de eventos.	test
SourceMySQLParameters	SourceMySQLParameters	Os parâmetros para a origem MySQL.
SourcePostgreSQLParameters	SourcePostgreSQLParameters
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters
Metadata	string
FilterPattern	string	A regra de filtragem de eventos. Se não for especificada, todos os eventos serão correspondidos.
Transforms	array<object>	A configuração do transformador de eventos.
	object	O Alibaba Cloud Resource Name (ARN) do serviço em nuvem, como o ARN de uma função no Function Compute.
Arn	string	O Alibaba Cloud Resource Name (ARN) do recurso em nuvem, como o ARN de uma função no Function Compute.	acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
DashScopeTransformParameters	DashScopeTransformParameters
BaiLianAgentTransformParameters	BaiLianAgentTransformParameters
Sink	object	O destino do evento.
SinkMNSParameters	object	Os parâmetros para o destino de evento Simple Message Queue (anteriormente MNS).
QueueName	object	O tipo de serviço de destino é Simple Message Queue (anteriormente MNS).
Value	string	O nome da fila Simple Message Queue (anteriormente MNS).	MyQueue
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
Body	object	O conteúdo da mensagem.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
IsBase64Encode	object	Indica se a decodificação Base64 está ativada.
Value	string	Especifica se a codificação Base64 deve ser ativada.	true
Form	string	O formato de transformação de eventos. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
SinkRabbitMQParameters	object	Os parâmetros para o sink RabbitMQ.
InstanceId	object	O tipo de serviço de destino é ApsaraMQ for RabbitMQ.
Value	string	O ID da instância ApsaraMQ for RabbitMQ.	e5c9b727-e06c-4d7e-84d5-f8ce644e****
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
VirtualHostName	object	O nome do vhost na instância ApsaraMQ for RabbitMQ.
Value	string	O nome do vhost na instância ApsaraMQ for RabbitMQ.	rabbit-host
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
TargetType	object	O tipo de destino.
Value	string	O tipo de destino. Valores válidos: Exchange: Modo Exchange. Queue: Modo Queue.	Exchange/Queue
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Exchange	object	O modo Exchange. Este parâmetro é obrigatório somente quando TargetType está definido como Exchange.
Value	string	O nome do exchange na instância ApsaraMQ for RabbitMQ.	a_exchange
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
RoutingKey	object	A regra de roteamento da mensagem. Este parâmetro.
Value	string	A regra de roteamento da mensagem.	housekeeping
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
QueueName	object	O modo Queue. Este parâmetro é obrigatório somente quando TargetType está definido como Queue.
Value	string	O nome da fila na instância.	MyQueue
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Body	object	O conteúdo da mensagem.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
MessageId	object	O ID da mensagem.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
Properties	object	As propriedades de filtro.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
SinkFcParameters	object	O destino de função.
ServiceName	object	O nome do serviço.
Value	string	O nome do serviço.	myService
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
FunctionName	object	O nome da função.
Value	string	O nome da função.	mFunction
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Concurrency	object	A concorrência de entrega. Valor mínimo: 1. [_single.resp.200.props.Data.Sink.SinkF
Value	string	A concorrência de entrega. Valor mínimo: 1.	1
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Qualifier	object	The service version.
Value	string	A versão do serviço.	LATEST
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
InvocationType	object	O tipo de invocação. Valores válidos: Sync: Síncrono. Async: Assíncrono.
Value	string	The invocation type. Valid values: Sync: Synchronous. Async: Asynchronous.	Async
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Body	object	O corpo do conteúdo enviado à função.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação. Valores válidos: ORIGINAL: evento completo JSONPATH: evento parcial CONSTANT: constante TEMPLATE: modelo Para mais informações, consulte Transformação de eventos.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
DataFormat	object	The format conversion rule for event content.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	The transformation format. Valid values: ORIGINAL: complete event JSONPATH: partial event CONSTANT: constant TEMPLATE: template	JSONPATH
Template	string	O modelo.	$.data.key
SinkKafkaParameters	object	The parameters for the Kafka sink.
InstanceId	object	O tipo de destino de evento é ApsaraMQ for Kafka.
Value	string	O ID da instância.	Defaut_1283278472_s****
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
DynamicTopic	object	Specifies the target topic strategy for message routing. If both the topic parameter and the DynamicTopic parameter are specified, the DynamicTopic parameter takes precedence. Two configuration modes are supported: 1. Static constant mode: Specify a fixed topic name string (such as "order_created"). All messages are sent to this topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (such as "$.user.id" or "$.metadata.category"). The system parses the upstream message body and extracts the value of the matching field as the target topic name.
Value	string	O valor.
Form	string	O tipo de transformação. Valores válidos: CONSTANT: valor fixo. JSONPATH: extraído do upstream com base no caminho.
Template	string	O modelo.
Topic	object	O tópico.
Value	string	The topic.	test
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
CompressionType	string
Acks	object	The acknowledgment mode for writing to Kafka. Valid values: acks=0: No response is required from the server. This mode delivers high performance but has a high risk of data loss. acks=1: A response is returned after the primary node writes successfully. This mode delivers moderate performance and has a moderate risk of data loss. Data loss may occur if the primary node goes down. acks=all: A response is returned only after the primary node writes successfully and the secondary nodes complete synchronization. This mode delivers lower performance but provides higher data security. Data loss occurs only if both the primary and secondary nodes go down.
Value	string	O modo de confirmação para escrita no Kafka. Valores válidos: acks=0: Nenhuma resposta é necessária do servidor. Este modo oferece alto desempenho, mas tem alto risco de perda de dados. acks=1: Uma resposta é retornada após o nó primário gravar com sucesso. Este modo oferece desempenho moderado e tem risco moderado de perda de dados. A perda de dados pode ocorrer se o nó primário falhar. acks=all: Uma resposta é retornada somente após o nó primário gravar com sucesso e os nós secundários completarem a sincronização. Este modo oferece menor desempenho, mas proporciona maior segurança de dados. A perda de dados ocorre somente se tanto os nós primários quanto os secundários falharem.	1
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Key	object	The message key.
Value	string	A chave da mensagem.	key
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Headers	object	Os metadados adicionais da mensagem Kafka.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	The transformation format. Valid values: ORIGINAL: complete event JSONPATH: partial event CONSTANT: constant TEMPLATE: template	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Value	object	The message body.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
SinkApacheKafkaParameters	object	As informações de descrição.
Bootstraps	string
Topic	string
DynamicTopic	object	Specifies the target topic strategy for message routing. If both the topic parameter and the DynamicTopic parameter are specified, the DynamicTopic parameter takes precedence. Two configuration modes are supported: 1. Static constant mode: Specify a fixed topic name string (such as "order_created"). All messages are sent to this topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (such as "$.user.id" or "$.metadata.category"). The system parses the upstream message body and extracts the value of the matching field as the target topic name.
Value	string	O valor.
Form	string	The transformation type. Valid values: CONSTANT: fixed value. JSONPATH: extracted from upstream based on the path.
Template	string	O modelo.
Acks	string
CompressionType	string
Key	object
Value	string
Form	string
Template	string
Headers	object
Value	string
Form	string
Template	string
Value	object
Value	string
Form	string
Template	string
SecurityProtocol	string
SaslMechanism	string
SaslUser	string
VpcId	object
Value	string
Form	string
Template	string
VSwitchIds	object
Value	string
Form	string
Template	string
SecurityGroupId	object
Value	string
Form	string
Template	string
NetworkType	object
Value	string
Form	string
Template	string
SaslPassword	string
SslTruststoreCertificates	string	[Required for SSL] The Kafka server trust certificate. Used to authenticate the validity of the Kafka Broker SSL certificate and prevent man-in-the-middle attacks. Format: Base64 encoding in PEM format, typically containing the CA certificate or the server certificate of the Kafka server. Example: Base64-encode the PEM file content of the CA certificate (ensure it starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----'). If Kafka uses a self-signed certificate, provide the CA certificate that issued the certificate.
SslKeystoreCertificateChain	string	[Obrigatório para autenticação mútua] A cadeia de certificados do cliente Kafka. Obrigatório quando o servidor Kafka habilita autenticação SSL mútua (ssl.client.auth=required). Formato: PEM codificado em Base64, contendo o certificado do cliente e a cadeia de certificados completa (certificado do cliente primeiro, certificado CA intermediário em seguida, certificado CA raiz opcional). Nota: certifique-se de que cada conteúdo de arquivo PEM comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----', depois codifique em Base64 o conteúdo concatenado.
SslKeyPassword	string	[Obrigatório para chave privada criptografada] A senha da chave privada do cliente Kafka. Obrigatório quando a chave privada do cliente é criptografada (o arquivo PEM contém marcadores 'Proc-Type: 4,ENCRYPTED' ou 'ENCRYPTED'). Deixe vazio se a chave privada não for criptografada. Nota: esta senha é usada apenas para descriptografar a chave privada e não está relacionada à autenticação do Kafka.
SslKeystoreKey	object	[Required for bidirectional authentication] The SSL private key configuration object. When the Kafka server enables bidirectional SSL authentication, you must provide the client private key. Only KMS pattern is supported: specify the Key Management Service EPS resource that stores the private key by using KmsArn. The system retrieves the private key content from KMS only in memory, which provides higher security. Configuration example: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}
KmsArn	string	[Obrigatório] O ARN do recurso KMS que armazena a chave privada SSL. Usado para localizar a instância KMS que armazena a chave privada do cliente. Exemplo de formato: 'acs:kms:ap-southeast-1:123456789:secret/ssl-keystore-key-xxxx'. Você pode visualizar o ARN da chave correspondente no console do KMS.
KmsSecretValueKey	string	[Modo KV do KMS] O nome da chave no segredo KMS. Quando o segredo KMS é armazenado em uma estrutura de chave-valor (KV), especifique este parâmetro para indicar a chave que corresponde à chave privada SSL. Exemplo: se o segredo KMS for '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', especifique 'ssl_keystore_key'. Deixe este parâmetro vazio se o segredo KMS estiver em modo de texto simples (armazena diretamente o conteúdo PEM da chave privada).
SinkRocketMQParameters	object	Sink RocketMQ Parameters
InstanceId	object	The event target type is ApsaraMQ for RocketMQ.
Value	string	O ID da instância ApsaraMQ for RocketMQ.	MQ_INST_164901546557**_BAAN**
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Topic	object	O tópico da instância ApsaraMQ for RocketMQ.
Value	string	The topic name of the ApsaraMQ for RocketMQ instance.	Mytopic
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.	The value of ${key} is ${value}!
Body	object	O conteúdo da mensagem.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
Properties	object	As propriedades de filtro.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
Keys	object	As propriedades de filtro.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
Tags	object	As propriedades de filtro.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
InstanceType	object	O tipo de instância. Valores válidos: Cloud_4: instância ApsaraMQ for RocketMQ 4.0 (padrão) Cloud_5: instância ApsaraMQ for RocketMQ 5.0 SelfBuilt: cluster Apache RocketMQ autogerenciado
Value	string	O tipo de instância. Valores válidos: Cloud_4: instância ApsaraMQ for RocketMQ 4.0 (padrão) Cloud_5: instância ApsaraMQ for RocketMQ 5.0 SelfBuilt: cluster Apache RocketMQ autogerenciado	Cloud_4
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
InstanceEndpoint	object	O endpoint da instância.
Value	string	O endpoint da instância.	vbr-8vbsvkkbpf3vb0zef****
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Nenhum.
InstanceUsername	object	O nome de usuário da instância.
Value	string	O nome de usuário da instância.	admin
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
InstancePassword	object	A senha da instância.
Value	string	A senha da instância.	admin****
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
VpcId	object	O ID da VPC.
Value	string	O ID da VPC.	vbr-8vb835n3zf9shwlvb****
Form	string	O formato de transformação de eventos. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
VSwitchIds	object	O ID do vSwitch.
Value	string	O ID do vSwitch.	vbr-8vb835n3zf9shwl****mp
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
SecurityGroupId	object	O ID do grupo de segurança.
Value	string	O ID do grupo de segurança.	b4bf375515f6440f942e3a20c33d****
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
Network	object	The network type. Valid values: PublicNetwork PrivateNetwork
Value	string	The network type. Valid values: PublicNetwork PrivateNetwork	PublicNetwork
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
DeliveryOrderType	object	The delivery order type of messages. This parameter is optional. The default value is concurrent delivery.
Value	string	The delivery order type. Valid values: Orderly: ordered delivery. Concurrently: concurrent delivery.	Concurrently
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
ShardingKey	object	A chave de particionamento da mensagem. Nota ShardingKey é obrigatório quando DeliveryOrderType está definido como Orderly. Quando Source é RocketMQ, ShardingKey pode ser deixado vazio. Neste caso, o BrokerName e QueueId upstream são concatenados para gerar o ShardingKey da mensagem.
Value	string	O valor da chave de particionamento.	order_id
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
SinkDorisParameters	object
QueryEndpoint	object
Value	string
Form	string
Template	string
FeHttpEndpoint	object
Value	string
Form	string
Template	string
BeHttpEndpoint	object
Value	string
Form	string
Template	string
UserName	object
Value	string
Form	string
Template	string
Password	object
Value	string
Form	string
Template	string
Database	object
Value	string
Form	string
Template	string
Table	object
Value	string
Form	string
Template	string
Body	object
Value	string
Form	string
Template	string
NetworkType	object
Value	string
Form	string
Template	string
VpcId	object
Value	string
Form	string
Template	string
VSwitchIds	object
Value	string
Form	string
Template	string
SecurityGroupId	object
Value	string
Form	string
Template	string
SinkRocketMQCheckpointParameters	object	Parâmetros de Checkpoint do Sink RocketMQ.
InstanceType	string	O tipo de instância. Valores válidos: Cloud_4: instância Alibaba Cloud RocketMQ 4.0. Cloud_5: instância Alibaba Cloud RocketMQ 5.0.	Cloud_4
InstanceId	string	O ID da instância.	MQ_INST_164901546557**_BAAN**
Topic	object	O tópico da instância ApsaraMQ for RocketMQ.
Value	string	The topic name of the ApsaraMQ for RocketMQ instance.	Mytopic
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
Group	object	The Group ID of the consumer group.
Value	string	Group ID	GID_EVENTBRIDGE_1736234******
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
ConsumeTimestamp	object	The timestamp of message consumption.
Value	string	The timestamp.	1570761026400
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
SinkApacheRocketMQCheckpointParameters	object	Parâmetros de Checkpoint do Sink Apache RocketMQ.
Topic	object	The topic of the RocketMQ instance.
Value	string	The topic name of the RabbitMQ instance.	Mytopic
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
Group	object	The Group ID of the consumer group.
Value	string	Group ID	GID_EVENTBRIDGE_1736234******
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
ConsumeTimestamp	object	The timestamp of message consumption.
Value	string	O timestamp.	1570761026400
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
InstanceEndpoint	string	O endpoint da instância.	192.168.1.1:9876
InstanceUsername	string	The username required for authentication.	admin
InstancePassword	string	The password for the username.	****
NetworkType	string	O tipo de rede.	PrivateNetwork
VpcId	string	O ID da VPC.	vpc-2zeccak5pb0j3ay******
VSwitchId	string	O ID do vSwitch.	vsw-uf62oqt1twuevrt******
SecurityGroupId	string	O ID do grupo de segurança.	sg-2ze5bmpw6adn0q******
SinkSLSParameters	object	Sink SLS Parameters
Project	object	O projeto do Simple Log Service.
Value	string	O projeto do Simple Log Service.	test-project
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
LogStore	object	O Logstore do Simple Log Service.
Value	string	O Logstore do Simple Log Service.	test-logstore
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
Topic	object	O tópico onde o log reside, correspondente ao campo reservado "topic" do Simple Log Service.
Value	string	The topic where the log resides, corresponding to the Simple Log Service reserved field "topic".	testTopic
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
Body	object	The content sent to Simple Log Service.
Value	string	O valor antes da transformação.	{ "key": "value" }
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	The value of ${key} is ${value}!
RoleName	object	To authorize the event bus EventBridge to use this role to read Simple Log Service log content, the following conditions must be met: when creating the role used by the service in the Resource Access Management (RAM) console, select "Alibaba Cloud Service", and set "Trusted Service" to "EventBridge".
Value	string	Para autorizar o barramento de eventos EventBridge a usar esta role para ler o conteúdo de logs do Simple Log Service, as seguintes condições devem ser atendidas: ao criar a role usada pelo serviço no console do Resource Access Management (RAM), selecione "Alibaba Cloud Service" e defina "Trusted Service" como "EventBridge".	testRole
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
ContentType	object	O formato de dados do Simple Log Service. Você pode selecionar o formato padrão ou configurar um par chave-valor especificado. Valores válidos: JSON KeyValue
Value	string	O valor antes da transformação.	JSON
Form	string	O formato de transformação.	CONSTANT
Template	string	O modelo.
ContentSchema	object	The key-value pairs of custom logs. This parameter takes effect only when ContentType is set to KeyValue. Each key-value pair is represented by Key_n and Value_n.
Value	string	O valor antes da transformação.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
Form	string	O modelo.	CONSTANT
Template	string	O modelo.
SinkFnfParameters	object	Os parâmetros do Sink CloudFlow.
FlowName	object	O nome do fluxo.
Value	string	The flow name.	test-streaming-fnf
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
ExecutionName	object	The execution name.
Value	string	The execution name.	123
Form	string	The transformation format. Default value: CONSTANT. Valid values: JSONPATH: partial event. CONSTANT: constant. TEMPLATE: template. For more information, see Event transformation.	CONSTANT
Template	string	O modelo.
Input	object	The execution input information.
Value	string	As informações de entrada da execução.	123
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
RoleName	object	The role configuration.
Value	string	The role configuration.	Al**FNF-x**
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O modelo.
SinkDataHubParameters	object	The Sink DataHub parameters.
Project	object	The DataHub project name.
Value	string	The DataHub project name.	demo-project
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
Topic	object	The DataHub topic name.
Value	string	O nome do tópico DataHub.	demo-topic
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
TopicType	object	O tipo de tópico. Valores válidos: TUPLE BLOB
Value	string	The topic type. Valid values: TUPLE BLOB	TUPLE
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Nenhum.
TopicSchema	object	The topic content schema for the TUPLE type.
Value	string	The topic content schema for the TUPLE type.	{"k1":"value1","k2":"value2"}
Form	string	O formato de transformação.	TEMPLATE
Template	string	O modelo.	{"k1":"${k1}","k2":"${k2}"}
Body	object	The record content template for the BLOB type.
Value	string	The record content template for the BLOB type.
Form	string	O formato de transformação.	ORIGINAL
Template	string	Nenhum.
RoleName	object	O nome da role da tarefa.
Value	string	O nome da role da tarefa.	test-role
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	None.
SinkCustomizedKafkaParameters	object	Os parâmetros do Sink Kafka.
InstanceId	string	O ID da instância ApsaraMQ for Kafka.	90be1f96-4229-4535-bb76-34b4f6fb****
SinkCustomizedKafkaConnectorParameters	object	The Sink Kafka connector parameters.
ConnectorPackageUrl	string	The OSS file download URL.	"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV******"
ConnectorParameters	object	Analisa o arquivo de propriedades no pacote ZIP atual.
Name	string	O nome do conector.	mongo-sink
Config	object	A configuração do conector.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
WorkerParameters	object	A configuração da instância.	{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }
SinkDashVectorParameters	object	The Sink DashVector parameters.
InstanceId	string	O ID da instância.	vrs-cn-lbj3ru1***
Collection	string	The collection name.	collection1
ApiKey	string	A chave de API criada no console do DashVector.	Q34nExQH7sQ****
Operation	string	O tipo de operação do banco de dados DashVector.	Upsert
Network	string	O tipo de rede.	PublicNetwork
PrimaryKeyId	object	The primary key ID for inserting or deleting records. If this field is not specified, a random primary key ID is used.
Form	string	O formato de transformação.	JSONPATH
Value	string	Se Form estiver definido como JSONPATH: o conteúdo extraído pelo JSONPath. Se Form estiver definido como TEMPLATE: a variável do modelo. Nota: O campo Value não pode exceder 10.240 caracteres.	$.data.requestId
Template	string	The primary key ID template. This parameter is required only when Form is set to TEMPLATE.	${ID}
Partition	object	A partição. Valor padrão: default.
Form	string	O formato de transformação.	CONSTANT
Value	string	If Form is set to CONSTANT: the constant value. If Form is set to JSONPATH: the content extracted by JSONPath. Note: The Value field cannot exceed 10,240 characters.	default
Template	string	None.
Vector	object	O vetor do registro a ser inserido no DashVector.
Form	string	O formato de transformação.	JSONPATH
Value	string	O conteúdo extraído pelo JSONPath. Nota: O campo Value não pode exceder 10.240 caracteres.	$.data.messageBody
Template	string	None.
DashVectorSchemaParameters	array<object>	As definições de campo de esquema para entradas de tabela ao inserir no DashVector. O resultado da transformação do conteúdo do evento deve estar em formato JSON.
	array<object>
Name	object
Form	string
Value	string
Template	string
Type	object
Form	string
Value	string
Template	string
Value	object
Form	string
Value	string
Template	string
SinkOpenSourceRabbitMQParameters	object	Sink Open Source RabbitMQ Parameters
Endpoint	string	The endpoint.	192.168.1.1:9876
VirtualHostName	string	The virtual host name of RabbitMQ.	vhost1
TargetType	string	The target type for message delivery. This parameter takes effect only when TargetType is set to Exchange.	Exchange
Exchange	string	The exchange name in RabbitMQ.	my-exchange
QueueName	string	The queue name in RabbitMQ. This parameter takes effect only when TargetType is set to Queue.	my-queue
Username	string	O nome de usuário para acessar a instância RabbitMQ.	admin
Password	string	A senha para acessar a instância RabbitMQ.	****
VpcId	string	O ID da VPC.	vpc-uf6of9452b2pba82c ****
VSwitchIds	string	O ID do vSwitch.	vsw-uf6of9452b2pba82c ****
SecurityGroupId	string	O ID do grupo de segurança.	sg-uf6of9452b2pba82c ****
NetworkType	string	O tipo de rede.	PublicNetwork
AuthType	string	O tipo de autenticação.	ACL
RoutingKey	object	A chave de roteamento da mensagem.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Value	string	O valor da chave de roteamento.	{"Form": "CONSTANT", "Value": "my-routing-key"}
Template	string	O modelo.	The value of ${key} is ${value}!
Body	object	O conteúdo do corpo da mensagem.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Value	string	O valor dos dados brutos.	{"key": "value"}
Template	string	O modelo.	The value of ${key} is ${value}!
MessageId	object	O identificador exclusivo da mensagem.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Value	string	O valor do ID da mensagem.	12345
Template	string	O modelo.
Properties	object	As propriedades adicionais da mensagem.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Value	string	O conteúdo da propriedade.	{"env": "prod"}
Template	string	O modelo.	The value of ${key} is ${value}!
SinkBaiLianParameters	SinkBaiLianParameters	Parâmetros do Sink BaiLian.
SinkDataWorksTriggerParameters	SinkDataWorksTriggerParameters
SinkHttpsParameters	SinkHttpsParameters	Os parâmetros de destino HTTPS.
SinkApiDestinationParameters	SinkApiDestinationParameters	Os parâmetros de destino ApiDestination.
SinkOSSParameters	SinkOSSParameters
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters
SinkMQTTParameters	SinkMQTTParameters
SinkAgentRunParameters	SinkAgentRunParameters
RunOptions	object	The runtime environment parameters.
MaximumTasks	integer	A concorrência.	2
RetryStrategy	object	A estratégia de repetição quando a entrega de eventos falha.
PushRetryStrategy	string	A estratégia de repetição. Valores válidos: BACKOFF_RETRY (repetição com recuo) e EXPONENTIALDECAY_RETRY (repetição com decaimento exponencial).	BACKOFF_RETRY
MaximumEventAgeInSeconds	number	O tempo máximo de repetição.	512
MaximumRetryAttempts	number	O número máximo de tentativas de repetição.	2
ErrorsTolerance	string	A política de tolerância a falhas. Valores válidos: NONE (sem tolerância a falhas) e ALL (tolerar todas as falhas).	ALL
DeadLetterQueue	object	Especifica se a fila de mensagens mortas deve ser ativada. Por padrão, a fila de mensagens mortas está desativada e as mensagens que excedem a política de repetição são descartadas.
Arn	string	O ARN da fila de mensagens mortas.	acs:ram::155020394332****:role/edskmstoecs
Network	string	O tipo de rede da fila de mensagens mortas.	PrivateNetwork
VpcId	string	O ID da VPC da fila de mensagens mortas.	vpc-2zehizpoendb3****
VSwitchIds	string	O ID do vSwitch da fila de mensagens mortas.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	O ID do grupo de segurança da instância onde a fila de mensagens mortas reside.	sg-2vcgdxz7o1n9zapp****
BatchWindow	object	A janela de lote.
CountBasedWindow	integer	O número máximo de eventos que a janela pode conter. Quando esse limite é atingido, os dados na janela são enviados downstream. Se existirem múltiplas janelas, um envio é acionado quando qualquer janela atingir o limite.	100
TimeBasedWindow	integer	O intervalo de tempo máximo (em segundos) dos eventos que a janela pode conter. Quando esse limite é atingido, os dados na janela são enviados downstream. Se existirem múltiplas janelas, um envio é acionado quando qualquer janela atingir o limite.	10
BusinessOption	object
BusinessMode	string
MinCapacityUnitCount	integer
MaxCapacityUnitCount	integer
Throttling	integer
Status	string	The status of the event stream.	RUNNING
DetailedStatus	object	The detailed status.
TPS	number	As transações por segundo.	5
DelayTime	integer	O tempo de atraso.	3
DiffOffset	integer	O offset de diferença.	0
Extensions	object	As propriedades de extensão.	{ "test": "test", "test2": 1 }
Code	string	The return code. Success indicates a successful request. For other fault codes, see the error code details.	Success
Success	boolean	Returns true if the operation is successful.	true

Exemplos

Resposta de sucesso

JSON formato

{
  "Message": "The event streaming [xxxx] not existed!",
  "RequestId": "7892F480-58C9-5067-AB35-8A7BEF****",
  "Data": {
    "EventStreamingName": "rocketmq-sync",
    "Description": "RocketMQ-to-RocketMQ",
    "Source": {
      "SourceMNSParameters": {
        "RegionId": "cn-hangzhou",
        "QueueName": "demo",
        "IsBase64Decode": true
      },
      "SourceRabbitMQParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-f8z9a9mcgwri1c1i****",
        "VirtualHostName": "eb-connect",
        "QueueName": "comp"
      },
      "SourceRocketMQParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-f8zbher64dlm58pl****",
        "Topic": "topic_add_anima",
        "Tag": "v1",
        "Offset": "CONSUMEFROMLASTOFFSET",
        "GroupID": "GID_group1",
        "Timestamp": 1636597951964,
        "InstanceType": "Cloud_4\n",
        "InstanceEndpoint": "reg****-vpc.cn-zhangjiakou.aliyuncs.com\n",
        "AuthType": "ACL",
        "InstanceUsername": "xxxa",
        "InstancePassword": "xxxa",
        "InstanceVpcId": "vpc-m5e3sv4b12345****\n",
        "InstanceVSwitchIds": "vsw-m5ev8asdc6h12****\n",
        "InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
        "InstanceNetwork": "PublicNetwork",
        "BodyDataType": "Json",
        "FilterType": "Tag\n",
        "FilterSql": "index > 10",
        "VpcId": "vpc-m5e3sv4b12345****\n",
        "VSwitchIds": "vsw-m5ev8asdc6h12345****\n",
        "SecurityGroupId": "sg-m5edtu24f12345****\n",
        "Network": "PublicNetwork"
      },
      "SourceRocketMQCheckpointParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceType": "Cloud_4",
        "InstanceId": "rmp-cn-jte3w******\n",
        "Topics": [
          "opic_add_anima"
        ]
      },
      "SourceApacheRocketMQCheckpointParameters": {
        "RegionId": "cn-hangzhou\n",
        "InstanceId": "MQ_INST_164901546557****_BAAN****",
        "Topics": [
          "[\"Topic_1\",\"Topic_2\"]"
        ],
        "InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
        "InstanceUsername": "admin",
        "InstancePassword": "123456",
        "NetworkType": "PrivateNetwork",
        "VpcId": "vpc-adw1awdw*****",
        "VSwitchId": "vsw-dwaafds****",
        "SecurityGroupId": "sg-mw43*****"
      },
      "SourceKafkaParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-bp1fbtrnqmjvgq66****",
        "Topic": "topic_empower_1642473600414",
        "ConsumerGroup": "GID_TEST",
        "OffsetReset": "latest",
        "Network": "Default",
        "VpcId": "vpc-2zehizpoendb3****",
        "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc****",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
        "ValueDataType": "Text"
      },
      "SourceMQTTParameters": {
        "RegionId": "cn-shanghai",
        "InstanceId": "i-2ze06wqdwk0uq14k****",
        "Topic": "TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel",
        "BodyDataType": "JSON",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": ""
      },
      "SourceDTSParameters": {
        "TaskId": "f86e5814-b223-482c-b768-3b873297****",
        "BrokerUrl": "",
        "Topic": "TP_TEST_UNDERWRITE_ISSUE",
        "Sid": "HD1",
        "Username": "admin",
        "Password": "admin****",
        "InitCheckPoint": "1620962769"
      },
      "SourceSLSParameters": {
        "Project": "dmmzk",
        "LogStore": "waf-logstore",
        "ConsumerGroup": "",
        "ConsumePosition": "begin",
        "RoleName": "testRole"
      },
      "SourcePrometheusParameters": {
        "RegionId": "cn-hangzhou",
        "ClusterId": "c83555068b6******ad213f565f209\n",
        "DataType": "Json",
        "Labels": "__name__=.*\n",
        "RoleName": "test-role",
        "ExternalLabels": "{\"env\":\"test\"}"
      },
      "SourceCustomizedKafkaParameters": {
        "InstanceId": "r-8vb64581862c****\n"
      },
      "SourceCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ\"",
        "ConnectorParameters": {
          "Name": "test-name\n",
          "Config": {
            "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
            "tasks.max": "1",
            "topics": "sourceA,sourceB"
          }
        },
        "WorkerParameters": {
          "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
          "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
          "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
          "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
          "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
          "bootstrap.servers": "alikafka-post:9092"
        }
      },
      "SourceApacheKafkaParameters": {
        "Bootstraps": "",
        "Topic": "",
        "ConsumerGroup": "",
        "OffsetReset": "",
        "ValueDataType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "SecurityProtocol": "",
        "SaslMechanism": "",
        "SaslUser": "",
        "SaslPassword": "",
        "SslTruststoreCertificates": "",
        "SslKeystoreCertificateChain": "",
        "SslKeyPassword": "",
        "SslKeystoreKey": {
          "KmsArn": "",
          "KmsSecretValueKey": ""
        }
      },
      "SourceOSSParameters": {
        "RoleName": "eventbridge_oss_role\n",
        "BucketName": "bucket_abc\n",
        "Prefix": "fun/document/\n",
        "LoadMode": "single\n",
        "LoadFormat": "TextLoader\n",
        "Delimiter": "\\n\n"
      },
      "SourceOpenSourceRabbitMQParameters": {
        "Endpoint": "192.168.1.100:5672",
        "VirtualHostName": "eb-connect",
        "QueueName": "demo",
        "BodyDataType": "Json",
        "Username": "admin",
        "Password": "******",
        "VpcId": "vpc-bp1vllc1lnw1v657******",
        "VSwitchIds": "vsw-uf65zhil5oukof5******",
        "SecurityGroupId": "sg-2ze65razphjfz3******",
        "NetworkType": "PrivateNetwork\n",
        "AuthType": "ACL"
      },
      "SourceEventBusParameters": {
        "EventBusName": "demo",
        "EventRuleName": "test"
      },
      "SourceMySQLParameters": {
        "RegionId": "",
        "HostName": "",
        "User": "",
        "Password": "",
        "DatabaseName": "",
        "TableNames": "",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "Port": 0,
        "SnapshotMode": "",
        "IncludeSchemaChanges": ""
      },
      "SourcePostgreSQLParameters": {
        "RegionId": "",
        "HostName": "",
        "Port": 0,
        "User": "",
        "Password": "",
        "DatabaseName": "",
        "SchemaName": "",
        "TableNames": "",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "SnapshotMode": ""
      },
      "SourceRabbitMQMetaParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Regex": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "MaxHops": "",
        "OrderConsume": "",
        "InnerNameSuffix": "",
        "SyncMetaType": ""
      },
      "SourceRabbitMQMsgSyncParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "OrderConsume": "",
        "BodyDataType": "",
        "PrefetchCount": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "SyncMetaType": "",
        "Regex": "",
        "SrcClusterType": "",
        "SrcClusterHost": "",
        "DstClusterType": "",
        "DstClusterHost": "",
        "CloudMigrationTaskId": ""
      },
      "SourceFeiShuDocsParameters": {
        "AppId": "",
        "AppSecret": "",
        "KnowledgeSpaceName": "",
        "LoadMode": ""
      }
    },
    "Metadata": "",
    "FilterPattern": "",
    "Transforms": [
      {
        "Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func\n",
        "DashScopeTransformParameters": {
          "Model": "",
          "ApiKey": "",
          "StructuredOutputJsonSchema": "",
          "RequestPerMinute": 0,
          "TokenPerMinute": 0,
          "Messages": [
            {
              "Role": "",
              "Form": "",
              "Value": "",
              "Template": ""
            }
          ]
        },
        "BaiLianAgentTransformParameters": {
          "ApplicationId": "",
          "Prompt": {
            "Form": "",
            "Value": "",
            "Template": ""
          },
          "ApiKey": "",
          "RequestPerMinute": 0,
          "TokenPerMinute": 0
        }
      }
    ],
    "Sink": {
      "SinkMNSParameters": {
        "QueueName": {
          "Value": "MyQueue",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "IsBase64Encode": {
          "Value": "true",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkRabbitMQParameters": {
        "InstanceId": {
          "Value": "e5c9b727-e06c-4d7e-84d5-f8ce644e****",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "VirtualHostName": {
          "Value": "rabbit-host\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "TargetType": {
          "Value": "Exchange/Queue",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Exchange": {
          "Value": "a_exchange",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "RoutingKey": {
          "Value": "housekeeping",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "QueueName": {
          "Value": "MyQueue",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "MessageId": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "Properties": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkFcParameters": {
        "ServiceName": {
          "Value": "myService",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "FunctionName": {
          "Value": "mFunction",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Concurrency": {
          "Value": "1",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Qualifier": {
          "Value": "LATEST",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "InvocationType": {
          "Value": "Async",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "DataFormat": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "JSONPATH",
          "Template": "$.data.key"
        }
      },
      "SinkKafkaParameters": {
        "InstanceId": {
          "Value": "Defaut_1283278472_s****",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "DynamicTopic": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Topic": {
          "Value": "test",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "CompressionType": "",
        "Acks": {
          "Value": "1",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Key": {
          "Value": "key",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Headers": {
          "Value": "{\n      \"key\": \"value\"\n}\n\n",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Value": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkApacheKafkaParameters": {
        "Bootstraps": "",
        "Topic": "",
        "DynamicTopic": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Acks": "",
        "CompressionType": "",
        "Key": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Headers": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Value": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SecurityProtocol": "",
        "SaslMechanism": "",
        "SaslUser": "",
        "VpcId": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "VSwitchIds": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SecurityGroupId": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "NetworkType": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SaslPassword": "",
        "SslTruststoreCertificates": "",
        "SslKeystoreCertificateChain": "",
        "SslKeyPassword": "",
        "SslKeystoreKey": {
          "KmsArn": "",
          "KmsSecretValueKey": ""
        }
      },
      "SinkRocketMQParameters": {
        "InstanceId": {
          "Value": "MQ_INST_164901546557****_BAAN****",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Topic": {
          "Value": "Mytopic",
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Properties": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Keys": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "Tags": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "InstanceType": {
          "Value": "Cloud_4\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "InstanceEndpoint": {
          "Value": "vbr-8vbsvkkbpf3vb0zef****\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "InstanceUsername": {
          "Value": "admin\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "InstancePassword": {
          "Value": "admin****\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "VpcId": {
          "Value": "vbr-8vb835n3zf9shwlvb****\n",
          "Form": "CONSTANT\n",
          "Template": "\n"
        },
        "VSwitchIds": {
          "Value": "vbr-8vb835n3zf9shwl****mp\n",
          "Form": "CONSTANT\n",
          "Template": "\n"
        },
        "SecurityGroupId": {
          "Value": "b4bf375515f6440f942e3a20c33d****\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "Network": {
          "Value": "PublicNetwork\n",
          "Form": "CONSTANT\n",
          "Template": "\n"
        },
        "DeliveryOrderType": {
          "Value": "Concurrently",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ShardingKey": {
          "Value": "order_id",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkDorisParameters": {
        "QueryEndpoint": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "FeHttpEndpoint": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "BeHttpEndpoint": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "UserName": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Password": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Database": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Table": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Body": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "NetworkType": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "VpcId": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "VSwitchIds": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SecurityGroupId": {
          "Value": "",
          "Form": "",
          "Template": ""
        }
      },
      "SinkRocketMQCheckpointParameters": {
        "InstanceType": "Cloud_4",
        "InstanceId": "MQ_INST_164901546557****_BAAN****",
        "Topic": {
          "Value": "Mytopic",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Group": {
          "Value": "GID_EVENTBRIDGE_1736234******",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ConsumeTimestamp": {
          "Value": "1570761026400",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkApacheRocketMQCheckpointParameters": {
        "Topic": {
          "Value": "Mytopic",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Group": {
          "Value": "GID_EVENTBRIDGE_1736234******\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ConsumeTimestamp": {
          "Value": "1570761026400",
          "Form": "CONSTANT",
          "Template": ""
        },
        "InstanceEndpoint": "192.168.1.1:9876",
        "InstanceUsername": "admin",
        "InstancePassword": "****",
        "NetworkType": "PrivateNetwork",
        "VpcId": "vpc-2zeccak5pb0j3ay******",
        "VSwitchId": "vsw-uf62oqt1twuevrt******",
        "SecurityGroupId": "sg-2ze5bmpw6adn0q******"
      },
      "SinkSLSParameters": {
        "Project": {
          "Value": "test-project\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "LogStore": {
          "Value": "test-logstore",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Topic": {
          "Value": "testTopic",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "RoleName": {
          "Value": "testRole",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ContentType": {
          "Value": "JSON\n",
          "Form": "CONSTANT\n",
          "Template": ""
        },
        "ContentSchema": {
          "Value": "{\"Key_1\":{\"form\":\"CONSTANT\",\"value\":\"demoKey\"},\"Value_1\":{\"form\":\"JSONPATH\",\"value\":\"$.data.value\"}}",
          "Form": "CONSTANT\n",
          "Template": ""
        }
      },
      "SinkFnfParameters": {
        "FlowName": {
          "Value": "test-streaming-fnf",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ExecutionName": {
          "Value": "123",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Input": {
          "Value": "123",
          "Form": "CONSTANT",
          "Template": ""
        },
        "RoleName": {
          "Value": "Al****FNF-x****",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkDataHubParameters": {
        "Project": {
          "Value": "demo-project\n",
          "Form": "CONSTANT\n",
          "Template": "\n\n"
        },
        "Topic": {
          "Value": "demo-topic\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "TopicType": {
          "Value": "TUPLE\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "TopicSchema": {
          "Value": "{\"k1\":\"value1\",\"k2\":\"value2\"}",
          "Form": "TEMPLATE",
          "Template": "{\"k1\":\"${k1}\",\"k2\":\"${k2}\"}"
        },
        "Body": {
          "Value": "",
          "Form": "ORIGINAL",
          "Template": ""
        },
        "RoleName": {
          "Value": "test-role",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkCustomizedKafkaParameters": {
        "InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb****"
      },
      "SinkCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV******\"",
        "ConnectorParameters": {
          "Name": "mongo-sink",
          "Config": {
            "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
            "tasks.max": "1",
            "topics": "sourceA,sourceB"
          }
        },
        "WorkerParameters": {
          "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
          "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
          "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
          "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
          "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
          "bootstrap.servers": "alikafka-post:9092"
        }
      },
      "SinkDashVectorParameters": {
        "InstanceId": "vrs-cn-lbj3ru1***",
        "Collection": "collection1",
        "ApiKey": "Q34nExQH7sQ****",
        "Operation": "Upsert",
        "Network": "PublicNetwork",
        "PrimaryKeyId": {
          "Form": "JSONPATH",
          "Value": "$.data.requestId",
          "Template": "${ID}"
        },
        "Partition": {
          "Form": "CONSTANT",
          "Value": "default",
          "Template": ""
        },
        "Vector": {
          "Form": "JSONPATH",
          "Value": "$.data.messageBody",
          "Template": ""
        },
        "DashVectorSchemaParameters": [
          {
            "Name": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Type": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Value": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          }
        ]
      },
      "SinkOpenSourceRabbitMQParameters": {
        "Endpoint": "192.168.1.1:9876",
        "VirtualHostName": "vhost1",
        "TargetType": "Exchange",
        "Exchange": "my-exchange",
        "QueueName": "my-queue",
        "Username": "admin",
        "Password": "****",
        "VpcId": "vpc-uf6of9452b2pba82c ****",
        "VSwitchIds": "vsw-uf6of9452b2pba82c ****",
        "SecurityGroupId": "sg-uf6of9452b2pba82c ****",
        "NetworkType": "PublicNetwork\n",
        "AuthType": "ACL",
        "RoutingKey": {
          "Form": "CONSTANT",
          "Value": "{\"Form\": \"CONSTANT\", \"Value\": \"my-routing-key\"}\n",
          "Template": "The value of ${key} is ${value}!"
        },
        "Body": {
          "Form": "CONSTANT",
          "Value": "{\"key\": \"value\"}",
          "Template": "The value of ${key} is ${value}!"
        },
        "MessageId": {
          "Form": "CONSTANT",
          "Value": "12345",
          "Template": ""
        },
        "Properties": {
          "Form": "CONSTANT",
          "Value": "{\"env\": \"prod\"}",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkBaiLianParameters": {
        "WorkspaceId": "",
        "ApplicationType": "",
        "Before": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "After": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Context": "",
        "Extend": "",
        "Op": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Partition": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Offset": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      },
      "SinkDataWorksTriggerParameters": {
        "Enable": ""
      },
      "SinkHttpsParameters": {
        "URL": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Method": "",
        "Body": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Token": "",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": ""
      },
      "SinkApiDestinationParameters": {
        "Name": "",
        "HeaderParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "BodyParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "QueryStringParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Timeout": 0
      },
      "SinkOSSParameters": {
        "BucketName": "",
        "RegionId": "",
        "Endpoint": "",
        "RoleArn": "",
        "RotateSizeBytes": "",
        "RotateIntervalMs": "",
        "PathFormat": "",
        "CompressionType": "",
        "TaskConcurrency": "",
        "TimeZone": "",
        "SSLEnabled": false,
        "ContentTransform": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      },
      "SinkRabbitMQMetaParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": ""
      },
      "SinkRabbitMQMsgSyncParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Body": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "MessageId": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Properties": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Exchange": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "RoutingKey": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "MaxHops": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": ""
      },
      "SinkMQTTParameters": {
        "InstanceId": "",
        "ParentTopic": "",
        "SubTopic": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Payload": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Mqtt5UserProperty": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      },
      "SinkAgentRunParameters": {
        "AgentRuntimeName": "",
        "EndpointName": "",
        "RoleName": "",
        "Body": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Timeout": ""
      }
    },
    "RunOptions": {
      "MaximumTasks": 2,
      "RetryStrategy": {
        "PushRetryStrategy": "BACKOFF_RETRY",
        "MaximumEventAgeInSeconds": 512,
        "MaximumRetryAttempts": 2
      },
      "ErrorsTolerance": "ALL",
      "DeadLetterQueue": {
        "Arn": "acs:ram::155020394332****:role/edskmstoecs",
        "Network": "PrivateNetwork",
        "VpcId": "vpc-2zehizpoendb3****",
        "VSwitchIds": "vsw-m5ev8asdc6h12345****",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****"
      },
      "BatchWindow": {
        "CountBasedWindow": 100,
        "TimeBasedWindow": 10
      },
      "BusinessOption": {
        "BusinessMode": "",
        "MinCapacityUnitCount": 0,
        "MaxCapacityUnitCount": 0
      },
      "Throttling": 0
    },
    "Status": "RUNNING",
    "DetailedStatus": {
      "TPS": 5,
      "DelayTime": 3,
      "DiffOffset": 0,
      "Extensions": {
        "test": "test",
        "test2": 1
      }
    }
  },
  "Code": "Success",
  "Success": true
}

Códigos de erro

Código de status HTTP	Código de erro	Mensagem de erro	Descrição
403	ServiceNotEnable	Service not enable

Consulte Códigos de Erro para uma lista completa.

Notas de versão

Consulte Notas de Versão para uma lista completa.