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

Consulta fluxos de eventos.

Descrição da operação

Consulta fluxos 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:ListEventStreamings

list

*EventStreaming.

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

Nenhuma

Parâmetros da solicitação

Parâmetro	Tipo	Obrigatório	Descrição	Exemplo
NamePrefix	string	Não	O prefixo do nome do fluxo de eventos.	name
Limit	integer	Não	Especifica o número máximo de entradas a serem retornadas por solicitação. Você pode usar este parâmetro junto com NextToken para paginar os resultados. Importante O número máximo de entradas retornadas por solicitação não pode exceder 100.	10
NextToken	string	Não	O token que é retornado quando Limit é especificado e há resultados adicionais disponíveis.	10
Tags	array<object>	Não	As tags usadas para filtrar resultados.
	object	Não	A tag.
Key	string	Não	A chave da tag.	mns
Value	string	Não	O valor da tag.	mnstest
SourceArn	string	Não	O ARN da origem do evento.	acs:alikafka:cn-hangzhou:118609547428**:instance/alikafka_pre-cn-zxu36kvi**/topic/test-topic
SinkArn	string	Não	O ARN do destino do evento.	acs:fc:cn-hangzhou:118609547428****:services/fw1.LATEST/functions/log1

Elementos de resposta

Elemento	Tipo	Descrição	Exemplo
	object	As informações da resposta.
Code	string	O código da resposta. Valores válidos:\n- Success: A solicitação foi bem-sucedida.\n- Outros valores: Códigos de erro. Para mais informações, consulte Códigos de erro.	Success
Data	object	A lista de fluxos de eventos.
EventStreamings	array<object>	A lista de fluxos de eventos.
	array<object>	A entidade do fluxo de eventos.
Description	string	A descrição do fluxo de eventos.	demo
EventStreamingName	string	O nome do fluxo de eventos.	name
FilterPattern	string	A regra de filtragem de eventos. Se este parâmetro não for especificado, todos os eventos são correspondidos.	{ "source": [ { "prefix": "acs:mns" } ], "type": [ { "prefix": "mns:Queue" } ], "subject": [ { "prefix": "acs:mns:cn-hangzhou:123456789098****:queues/zeus" } ] }
Metadata	string	As configurações JSON comuns do provedor de eventos. Este parâmetro e Source são mutuamente exclusivos.	{"key":"value"}
RunOptions	object	Os parâmetros do ambiente de execução.
BatchWindow	object	A janela de lotes.
CountBasedWindow	integer	O número máximo de eventos que a janela pode acomodar. Quando esse limite é atingido, os dados na janela são enviados para o downstream. Se existirem várias janelas, o envio é acionado quando a condição de qualquer janela for atendida.	100
TimeBasedWindow	integer	O intervalo de tempo máximo em segundos para os eventos que a janela pode acomodar. Quando esse limite é atingido, os dados na janela são enviados para o downstream. Se existirem várias janelas, o envio é acionado quando a condição de qualquer janela for atendida.	10
BusinessOption	object	As opções de negócios.
BusinessMode	string	O modo de negócios.	"BusinessMode"
MaxCapacityUnitCount	integer	O número máximo de unidades de capacidade.	10
MinCapacityUnitCount	integer	O número mínimo de unidades de capacidade.	1
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 nova tentativa são descartadas.
Arn	string	O ARN da fila de mensagens mortas.	acs:ram::159787121179****:role/aliyunsaedefaultrole
Network	string	O tipo de rede da fila de mensagens mortas.	PrivateNetwork
SecurityGroupId	string	O ID do grupo de segurança ao qual a instância da fila de mensagens mortas pertence.	sg-2vcgdxz7o1n9zapp****
VSwitchIds	string	O ID do vSwitch ao qual a fila de mensagens mortas pertence.	vsw-m5ev8asdc6h12345****
VpcId	string	O ID da VPC à qual a fila de mensagens mortas pertence.	vpc-2zehizpoendb3****
ErrorsTolerance	string	A política de tolerância a erros. Valores válidos:\n- NONE: Nenhum erro é tolerado.\n- ALL: Todos os erros são tolerados.	ALL
MaximumTasks	integer	O número de tarefas simultâneas.	2
RetryStrategy	object	A política de nova tentativa usada quando o envio de um evento falha.
PushRetryStrategy	string	A política de nova tentativa. Valores válidos:\n- BACKOFF_RETRY: Nova tentativa com backoff.\n- EXPONENTIAL_DECAY_RETRY: Nova tentativa com decaimento exponencial.	EXPONENTIAL_DECAY_RETRY
Throttling	integer	O valor de limitação.	100
Sink	object	O destino do evento.
SinkAgentRunParameters	SinkAgentRunParameters	Os parâmetros de entrega para o tempo de execução do agente.
SinkApacheRocketMQCheckpointParameters	object	Os parâmetros de checkpoint do Apache RocketMQ do destino.
ConsumeTimestamp	object	O carimbo de data e hora de consumo.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O carimbo de data e hora.	1636597951964
Group	object	As informações do grupo de consumidores do Apache RocketMQ.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O ID do grupo do grupo de consumidores.	GID_******
InstanceEndpoint	string	O endpoint da instância do Apache RocketMQ.	192.168.1.1:9876
InstancePassword	string	A senha da instância do Apache RocketMQ.	yourPassword
InstanceUsername	string	O nome de usuário da instância do Apache RocketMQ.	admin
NetworkType	string	O tipo de rede.	PrivateNetwork
SecurityGroupId	string	O ID do grupo de segurança.	sg-2vcgdxz7o1n9zapp****
Topic	object	O nome do tópico da instância do Apache RocketMQ.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome do tópico.	myTopic
VSwitchId	string	O ID do vSwitch.	vsw-wz9qqeovkwjxlu9uc****
VpcId	string	O ID da VPC.	vpc-2zehizpoendb3****
SinkApiDestinationParameters	SinkApiDestinationParameters	Os parâmetros de destino do ApiDestination.
SinkBaiLianParameters	SinkBaiLianParameters	Os parâmetros do BaiLian do destino.
SinkCustomizedKafkaConnectorParameters	object	Os parâmetros do conector Kafka do destino.
ConnectorPackageUrl	string	A URL de download do arquivo 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	O arquivo de propriedades analisado a partir do pacote ZIP atual.
Config	object	A configuração do conector.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
Name	string	O nome do conector.	mongo-sink
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" }
SinkCustomizedKafkaParameters	object	Os parâmetros do Kafka do destino.
InstanceId	string	O ID da instância do MSMQ para Apache Kafka.	90be1f96-4229-4535-bb76-34b4f6fb2b71
SinkDashVectorParameters	object	Os parâmetros do DashVector do destino.
ApiKey	string	A chave de API criada no console do DashVector.	Q34nExQH7sQ****
Collection	string	O nome da coleção.	collection1
DashVectorSchemaParameters	array<object>	As definições de campos de esquema para entradas de tabela ao inserir dados no DashVector. O conteúdo do evento transformado deve estar no formato JSON.
	array<object>
Name	object	O nome da propriedade.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome da propriedade.	content
Type	object	O tipo de propriedade do DashVector.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O tipo de propriedade do DashVector.	STRING
Value	object	O valor da propriedade.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	JSONPATH
Template	string	O estilo do modelo.	${content}
Value	string	O valor da propriedade.	$.data.content
InstanceId	string	O ID da instância.	vrs-cn-lbj3ru1***
Network	string	O tipo de rede.	PublicNetwork
Operation	string	O tipo de operação do banco de dados DashVector.	Upsert
Partition	object	A partição. Valor padrão: default.
Form	string	O formato de transformação.	CONSTANT
Template	string	O estilo do modelo.	${partition}
Value	string	CONSTANT: O valor constante. JSONPATH: O conteúdo extraído usando JSONPath. Nota: O campo Value não pode exceder 10.240 caracteres.	default
PrimaryKeyId	object	O ID da chave primária usado ao inserir ou excluir um registro. Se você não especificar este campo, um ID de chave primária aleatório será usado.
Form	string	O formato de transformação.	JSONPATH
Template	string	O modelo de ID da chave primária. Este campo é obrigatório apenas quando Form está definido como TEMPLATE.	${ID}
Value	string	JSONPATH: O conteúdo extraído usando JSONPath. TEMPLATE: A variável de modelo. Nota: O campo Value não pode exceder 10.240 caracteres.	$.data.requestId
Vector	object	O vetor do registro DashVector a ser inserido.
Form	string	O formato de transformação.	JSONPATH
Template	string	O estilo do modelo.	${vector}
Value	string	O conteúdo extraído usando JSONPath. Nota: O campo Value não pode exceder 10.240 caracteres.	$.data.messageBody
SinkDataHubParameters	object	Os parâmetros do sink do DataHub.
Body	object	O modelo de conteúdo do registro para o tipo BLOB.
Form	string	O formato de transformação.	ORIGINAL
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O modelo de conteúdo do registro para o tipo BLOB.	{ "key": "value" }
Project	object	O nome do projeto DataHub.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome do projeto DataHub.	demo-project
RoleName	object	Requisitos para a autorização do barramento de eventos EventBridge para usar esta função para ler logs do Simple Log Service: ao criar a função usada pelo serviço no console Resource Access Management (RAM), você deve selecionar Alibaba Cloud Service e selecionar o barramento de eventos como o serviço confiável.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	Requisitos para a autorização do barramento de eventos EventBridge para usar esta função para ler logs do Simple Log Service: ao criar a função usada pelo serviço no console Resource Access Management (RAM), você deve selecionar Alibaba Cloud Service e selecionar o barramento de eventos como o serviço confiável.	testRole
Topic	object	O nome do tópico DataHub.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome do tópico DataHub.	demo-topic
TopicSchema	object	O esquema de conteúdo do tópico para o tipo TUPLE.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	{"k1":"${k1}","k2":"${k2}"}
Value	string	O esquema de conteúdo do tópico para o tipo TUPLE.	{"k1":"value1","k2":"value2"}
TopicType	object	O tipo de tópico. Valores válidos: TUPLE BLOB
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O tipo de tópico. Valores válidos: TUPLE BLOB	TUPLE
SinkDorisParameters	object	O tipo de origem do evento.
BeHttpEndpoint	object	O endpoint HTTP público do BE.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O endpoint HTTP público do BE.	"BeHttpEndpoint"
Body	object	O conteúdo da mensagem.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O conteúdo da mensagem.	{ "key": "value" }
Database	object	O banco de dados.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O banco de dados.	"Database"
FeHttpEndpoint	object	O endpoint HTTP do FE.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O endpoint HTTP do FE.	"FeHttpEndpoint"
NetworkType	object	O tipo de rede.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O tipo de rede.	PublicNetwork
Password	object	A senha.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	A senha.	yourPassword
QueryEndpoint	object	O endpoint do protocolo MySQL.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O endpoint do protocolo MySQL.	"QueryEndpoint"
SecurityGroupId	object	O ID do grupo de segurança.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O ID do grupo de segurança.	sg-mw43*****
Table	object	A tabela de destino.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	A tabela de destino.	"Table"
UserName	object	O nome de usuário.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome de usuário.	"UserName"
VSwitchIds	object	Os IDs dos vSwitches.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	Os IDs dos vSwitches.	vbr-8vb835n3zf9shwl****mp
VpcId	object	O ID da VPC.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O ID da VPC.	i-2ze7u5i17mbqtx1p****
SinkEventHouseParameters	object	O nome do destino do evento.
CatalogName	string	O nome do catálogo.	cat1
EventTableName	string	O nome da tabela.	table1
MappingRules	array<object>	As regras de mapeamento de campos.
	array<object>	A regra de mapeamento.
ColumnName	string	O nome da coluna.	age
ColumnType	string	O tipo da coluna.	text
ColumnValue	object	A regra de extração de valor da coluna.
Form	string	O método de extração.	JSONPATH
Template	string	O modelo.	The value of ${key} is ${value}!
Value	string	O caminho de extração.	$.data.value
NamespaceName	string	O nome do namespace.	name1
SinkFcParameters	object	O destino da função.
Body	object	O corpo da solicitação enviado para a função.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
Concurrency	object	A concorrência de entrega. O valor mínimo é 1.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	A concorrência de entrega. O valor mínimo é 1.	1
DataFormat	object	A regra de transformação para o formato do conteúdo do evento.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
FunctionName	object	O nome da função.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O nome da função.	mFunction
InvocationType	object	O tipo de invocação. Valores válidos:\n- Sync: Síncrono.\n- Async: Assíncrono.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O tipo de invocação. Valores válidos:\n- Sync: Síncrono.\n- Async: Assíncrono.	Async
Qualifier	object	O alias do serviço ao qual a função pertence.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O alias do serviço ao qual a função pertence.	LATEST
ServiceName	object	O nome do serviço.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O nome do serviço.	myService
SinkFnfParameters	object	Os parâmetros do FnF para o destino.
ExecutionName	object	O nome da execução.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome da execução.	123
FlowName	object	O nome do fluxo.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome do fluxo.	test-streaming-fnf
Input	object	As informações de entrada para a execução.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	As informações de entrada para a execução.	123
RoleName	object	A configuração da função.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	A configuração da função.	Al**FNF-x**
SinkHttpsParameters	SinkHttpsParameters	Os parâmetros do destino HTTPS.
SinkKafkaParameters	object	Os parâmetros do Kafka para o destino.
Acks	object	O modo de confirmação para gravação no Kafka. Valores válidos:\n- acks=0: Nenhuma resposta do servidor é necessária. Este modo oferece alto desempenho, mas apresenta alto risco de perda de dados.\n- acks=1: Uma resposta é retornada após o nó primário gravar os dados com sucesso. Este modo oferece desempenho médio e apresenta risco médio de perda de dados. Os dados podem ser perdidos se o nó primário cair.\n- acks=all: Uma resposta é retornada após o nó primário gravar os dados com sucesso e os nós secundários sincronizarem os dados com sucesso. Este modo oferece baixo desempenho, mas garante alta segurança dos dados. Os dados são perdidos apenas quando os nós primário e secundários caem.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O modo de confirmação para gravação no Kafka. Valores válidos:\n- acks=0: Nenhuma resposta do servidor é necessária. Este modo oferece alto desempenho, mas apresenta alto risco de perda de dados.\n- acks=1: Uma resposta é retornada após o nó primário gravar os dados com sucesso. Este modo oferece desempenho médio e apresenta risco médio de perda de dados. Os dados podem ser perdidos se o nó primário cair.\n- acks=all: Uma resposta é retornada após o nó primário gravar os dados com sucesso e os nós secundários sincronizarem os dados com sucesso. Este modo oferece baixo desempenho, mas garante alta segurança dos dados. Os dados são perdidos apenas quando os nós primário e secundários caem.	1
CompressionType	string	O tipo de compactação.	"CompressionType"
DynamicTopic	object	A política de roteamento de tópico de destino para mensagens. Se os parâmetros topic e topics forem especificados, o valor do parâmetro topics prevalecerá. Os seguintes modos de configuração são suportados:\n1. Modo de constante estática: Insira uma string de nome de tópico fixa, como "order_created". Todas as mensagens são enviadas para este tópico.\n2. Modo de extração dinâmica: Insira uma expressão JSONPath padrão, como "$.user.id" ou "$.metadata.category". O sistema analisa o corpo da mensagem upstream e extrai o valor do campo correspondente como o nome do tópico de destino.
Form	string	O tipo de transformação. Valores válidos:\n- CONSTANT: valor fixo\n- JSONPATH: extraído do upstream com base no caminho.	CONSTANT
Template	string	O modelo.	Template string (if any)
Value	string	O valor.	"DynamicTopic"
InstanceId	object	O tipo de serviço de destino é o MSMQ para Apache Kafka.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O ID da instância.	Defaut_1283278472_sad****
Key	object	O identificador da mensagem.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O identificador da mensagem.	key
Topic	object	O nome do tópico.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O nome do tópico.	topic
Value	object	O conteúdo do corpo da mensagem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
SinkKnowledgeBaseParameters	SinkKnowledgeBaseParameters	Os parâmetros de entrega da base de conhecimento.
SinkMNSParameters	object	O destino do evento para o Simple MSMQ (anteriormente MNS).
Body	object	O conteúdo da mensagem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
IsBase64Encode	object	Especifica se a codificação Base64 deve ser ativada.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	Especifica se a codificação Base64 está ativada.	true
QueueName	object	O tipo de serviço de destino é o Simple MSMQ (anteriormente MNS).
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O nome da fila no Simple MSMQ (anteriormente MNS).	MyQueue
SinkMQTTParameters	SinkMQTTParameters	Os parâmetros de entrega do MQTT.
SinkOSSParameters	SinkOSSParameters	Os parâmetros de entrega do Object Storage Service (OSS).
SinkOpenSourceRabbitMQParameters	object	Os parâmetros do RabbitMQ de código aberto para o destino.
AuthType	string	O tipo de autenticação.	ACL
Body	object	O conteúdo da mensagem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
Endpoint	string	O endpoint da instância do RabbitMQ.	192.168.1.1:9876
Exchange	string	O nome do exchange usado para o roteamento de mensagens.	my_exchange
MessageId	object	O ID da mensagem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
NetworkType	string	O tipo de rede.	PrivateNetwork
Password	string	O nome de usuário e a senha usados para autenticação e verificação de identidade.	yourPassword
Properties	object	As propriedades de filtragem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
QueueName	string	O nome da fila usada para armazenar mensagens.	my_queue
RoutingKey	object	A regra de roteamento para a mensagem. Este parâmetro é necessário apenas quando o parâmetro TargetType está definido como Exchange.
Form	string	O formato dos dados. Valor padrão: JSONPATH.	JSONPATH
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	A regra de roteamento para a mensagem.	housekeeping
SecurityGroupId	string	O ID do grupo de segurança.	sg-2vcgdxz7o1n9zapp****
TargetType	string	O tipo de destino.	exchange
Username	string	O nome de usuário usado para autenticação e verificação de identidade.	admin
VSwitchIds	string	O ID do vSwitch.	vsw-wz9qqeovkwjxlu9uc****
VirtualHostName	string	O nome do host virtual no RabbitMQ.	Vhost1
VpcId	string	O ID da VPC.	vpc-2zehizpoendb3****
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters	Os parâmetros de entrega de metadados para a fila de mensagens MSMQ RabbitMQ Edition.
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters	Os parâmetros de entrega de sincronização de mensagens para a fila de mensagens MSMQ RabbitMQ Edition.
SinkRabbitMQParameters	object	Os parâmetros para o destino do RabbitMQ.
Body	object	O conteúdo da mensagem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
Exchange	object	O modo de exchange. Este parâmetro é obrigatório apenas quando o parâmetro TargetType é definido como Exchange.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O nome do exchange na instância do MSMQ message queue RabbitMQ Edition.	a_exchange
InstanceId	object	O tipo de serviço de destino é o MSMQ message queue RabbitMQ Edition.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O ID da instância do MSMQ message queue RabbitMQ Edition.	si-296cd57939a1421b****
MessageId	object	O ID da mensagem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
Properties	object	As propriedades de filtragem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
QueueName	object	O modo de fila. Este parâmetro é obrigatório apenas quando o parâmetro TargetType é definido como Queue.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O nome da fila na instância.	MyQueue
RoutingKey	object	A regra de roteamento para a mensagem. Este parâmetro é necessário apenas quando o parâmetro TargetType está definido como Exchange.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	A regra de roteamento para a mensagem.	housekeeping
TargetType	object	O tipo de destino.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O tipo de destino. Valores válidos: Exchange: Modo de exchange. Queue: Modo de fila.	Queue
VirtualHostName	object	O nome do vhost na instância do MSMQ message queue RabbitMQ Edition.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome do vhost na instância do MSMQ message queue RabbitMQ Edition.	rabbit-host
SinkRocketMQCheckpointParameters	object	Os parâmetros para o sink de checkpoint do RocketMQ.
ConsumeTimestamp	object	O carimbo de data e hora de consumo.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O carimbo de data e hora.	1636597951964
Group	object	As informações do grupo de consumidores do MSMQ message queue RocketMQ Edition.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O ID do grupo do grupo de consumidores.	GID_******
InstanceId	string	O ID da instância do RocketMQ.	MQ_INST_1825725063814405_BZ******
InstanceType	string	O tipo de instância do MSMQ message queue RocketMQ Edition.	Cloud_5
Topic	object	O tópico da instância do MSMQ message queue RocketMQ Edition.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome do tópico.	myTopic
SinkRocketMQParameters	object	Os parâmetros do sink do ApsaraMQ for RocketMQ.
Body	object	O conteúdo da mensagem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
DeliveryOrderType	object	O tipo de ordem de entrega da mensagem.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O tipo de ordem de entrega.	Orderly
InstanceEndpoint	object	O endpoint da instância.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O endpoint da instância.	vbr-8vbsvkkbpf3vb0zef****
InstanceId	object	O tipo de serviço de destino é o message queue MSMQ for RocketMQ.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O ID da instância do message queue MSMQ for RocketMQ.	MQ_INST_164901546557**_BAAN**
InstancePassword	object	A senha da instância.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	A senha da instância.	admin******
InstanceType	object	O tipo de instância.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O tipo de instância. Valores válidos: Cloud_4: Instância do ApsaraMQ for RocketMQ 4.0 (padrão). Cloud_5: Instância do ApsaraMQ for RocketMQ 5.0. SelfBuilt: Cluster Apache RocketMQ autogerenciado.	Cloud_4
InstanceUsername	object	O nome de usuário da instância.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O nome de usuário da instância.	admin
Keys	object	As propriedades de filtragem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
Network	object	O tipo de rede. Valores válidos:\n- PublicNetwork\n- PrivateNetwork.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O tipo de rede. Valores válidos:\n- PublicNetwork\n- PrivateNetwork.	PublicNetwork
Properties	object	As propriedades de filtragem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
SecurityGroupId	object	O ID do grupo de segurança.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O ID do grupo de segurança.	b4bf375515f6440f942e3a20c33d****
ShardingKey	object	A chave de sharding da mensagem, que é usada para controlar o particionamento de mensagens.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O valor da chave de sharding.	order_id
Tags	object	As propriedades de filtragem.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
Topic	object	O tópico da fila de mensagens MSMQ para a instância do RocketMQ.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O tópico da fila de mensagens MSMQ para a instância do RocketMQ.	topic
VSwitchIds	object	O ID do vSwitch.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O ID do vSwitch.	vbr-8vb835n3zf9shwl****mp
VpcId	object	O ID da VPC.
Form	string	O formato de transformação de evento. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O ID da VPC.	vbr-8vb835n3zf9shwlvb****
SinkSLSParameters	object	Os parâmetros do sink do Simple Log Service.
Body	object	O conteúdo enviado ao Simple Log Service.
Form	string	O formato de transformação.	TEMPLATE
Template	string	O estilo do modelo.	The value of ${key} is ${value}!
Value	string	O valor antes da transformação.	{ "key": "value" }
ContentSchema	object	Os pares chave-valor do log personalizado. Este parâmetro entra em vigor apenas quando ContentType é definido como KeyValue. Cada par chave-valor é representado por Key_n e Value_n.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O valor antes da transformação.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
ContentType	object	O formato de dados do Simple Log Service (SLS). Valores válidos:\n\n- JSON\n- KeyValue.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O formato de dados do Simple Log Service (SLS). Valores válidos:\n\n- JSON\n- KeyValue.	JSON
LogStore	object	O Logstore do Simple Log Service (SLS).
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O Logstore do Simple Log Service (SLS).	test-logstore
Project	object	O projeto do Simple Log Service (SLS).
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O projeto do Simple Log Service (SLS).	test-project
RoleName	object	Ao conceder autorização ao barramento de eventos EventBridge para usar esta função para ler o conteúdo de log do SLS, as seguintes condições devem ser atendidas: ao criar a função usada pelo serviço no console do Resource Access Management (RAM), você deve selecionar Alibaba Cloud Service e selecionar barramento de eventos como o serviço confiável.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	Ao conceder autorização ao barramento de eventos EventBridge para usar esta função para ler o conteúdo de log do SLS, as seguintes condições devem ser atendidas: ao criar a função usada pelo serviço no console do Resource Access Management (RAM), você deve selecionar Alibaba Cloud Service e selecionar barramento de eventos como o serviço confiável.	test-role
Topic	object	O tópico do log. Isso corresponde ao campo reservado topic no SLS.
Form	string	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	O estilo do modelo.	Template string (if any)
Value	string	O tópico do log. Isso corresponde ao campo reservado topic no SLS.	topic
Source	object	A origem do evento.
SourceApacheRocketMQCheckpointParameters	object	A origem de checkpoint do Apache RocketMQ.
InstanceEndpoint	string	O endpoint da instância do Apache RocketMQ.	192.168.1.1:9876
InstancePassword	string	A senha da instância do Apache RocketMQ.	yourPassword
InstanceUsername	string	O nome de usuário da instância do Apache RocketMQ.	admin
NetworkType	string	O tipo de rede.	PrivateNetwork
RegionId	string	O ID da região.	cn-hangzhou
SecurityGroupId	string	O ID do grupo de segurança.	sg-mw43*****
Topics	array	O tópico da instância do Apache RocketMQ.
	string	O tópico da instância do Apache RocketMQ.	myTopic
VSwitchId	string	O ID do vSwitch.	vsw-dwaafds****
VpcId	string	O ID da VPC.	vpc-adw1awdw*****
SourceCustomizedKafkaConnectorParameters	object	A origem de evento do conector personalizado do Apache Kafka.
ConnectorPackageUrl	string	A URL de download do pacote ZIP 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.
Config	object	A configuração do conector.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
Name	string	O nome do conector.	test-name
WorkerParameters	object	As configurações da instância do Kafka.	{ "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" }
SourceCustomizedKafkaParameters	object	A origem de eventos Kafka personalizada.
InstanceId	string	O ID da instância.	gtm-cn-k2c2yfg****
SourceDTSParameters	object	A origem do DTS.
BrokerUrl	string	O endereço de rede e o número da porta do canal de assinatura de dados.	"BrokerUrl"
InitCheckPoint	string	O ponto de verificação de consumo, que é o carimbo de data e hora em que o cliente SDK consome o primeiro registro de dados. O valor é um carimbo de data e hora UNIX.	1620962769
Password	string	A senha da conta do grupo de consumidores.	123456
Sid	string	O ID do grupo de consumidores.	HG9
TaskId	string	O ID da tarefa.	1611b337285f44e2936a2c4170****
Topic	string	O tópico de assinatura do canal de assinatura de dados.	TP_TEST_UNDERWRITE_ISSUE
Username	string	O nome de usuário da conta do grupo de consumidores.	admin
SourceEventBusParameters	object	A origem do barramento de eventos.
EventBusName	string	O nome do barramento de eventos.	my-event-bus
EventRuleName	string	O nome da regra de evento.	my-event-rule
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters	Os parâmetros de origem do documento do Lark.
SourceJDBCParameters	SourceJDBCParameters	Os parâmetros da origem de dados JDBC.
SourceKafkaParameters	object	A origem do Kafka.
ConsumerGroup	string	O ID do grupo do consumidor que assina o tópico.	GID_TEST
InstanceId	string	O ID da instância.	bastionhost-cn-i7m2gwt****
Network	string	A configuração de rede. Valor padrão: Default. Defina o valor como PublicNetwork para uma VPC.	Default
OffsetReset	string	O offset.	latest
RegionId	string	O ID da região da instância.	cn-chengdu
SecurityGroupId	string	O ID do grupo de segurança.	sg-5ud5f3p0rqqis69****eho7cp
Topic	string	O nome do tópico.	topic_empower_1642473600414
VSwitchIds	string	O ID do vSwitch.	vsw-bp1rmi8rind7eo50c****
ValueDataType	string	O formato de codificação e decodificação do corpo da mensagem. Valores válidos: JSON Text Binary	JSON
VpcId	string	O ID da VPC.	vpc-wz9ki1qdlx3cx5cbf****
SourceMNSParameters	object	A origem do Simple Message Queue (anteriormente MNS).
IsBase64Decode	boolean	Especifica se a codificação Base64 deve ser ativada.	true
QueueName	string	O nome da fila do Simple Message Queue (anteriormente MNS).	work4
RegionId	string	O ID da região.	cn-zhangjiakou
SourceMQTTParameters	object	A origem de eventos MQTT.
BodyDataType	string	O formato de codificação da mensagem. Valores válidos: JSON Text Binary	JSON
InstanceId	string	O ID da instância.	bastionhost-cn-zvp27kc****
NetworkType	string	O tipo de rede.	PrivateNetwork
RegionId	string	O ID da região.	cn-qingdao
SecurityGroupId	string	O ID do grupo de segurança.	sg-bp1iv19sp1msc7zot4****
Topic	string	O nome do tópico.	migration_instance
VSwitchIds	string	Os IDs dos vSwitches.	vsw-bp179l3llg3jjxwrq72****
VpcId	string	O ID da VPC.	vpc-8vblalsi0vbhizr77****
SourceMySQLParameters	SourceMySQLParameters	A origem de eventos MySQL.
SourceOSSParameters	object	A origem de eventos OSS.
BucketName	string	O nome do bucket do OSS.	bucket_abc
Delimiter	string	O delimitador. No modo de carregamento de blocos, este delimitador é usado como o identificador de bloco para texto. O valor padrão é o caractere de nova linha \n.	\n
LoadFormat	string	O carregador de documentos.	TextLoader
LoadMode	string	O modo de carregamento de dados. Valores válidos: single: Carregamento de documento único. element: Carregamento de blocos. Valor padrão: single.	single
Prefix	string	O prefixo do caminho do arquivo.	fun/document/
RoleName	string	O nome da função RAM que concede autorização ao barramento de eventos do EventBridge para ler arquivos do OSS. A função deve ter pelo menos permissões de somente leitura no OSS.	eventbridge_oss_role
SourceOpenSourceRabbitMQParameters	object	A origem de eventos RabbitMQ de código aberto.
AuthType	string	O tipo de autenticação.	ACL
BodyDataType	string	O tipo de dados do corpo da mensagem.	Json
Endpoint	string	O endpoint da instância.	192.168.1.1:9876
NetworkType	string	O tipo de rede.	PrivateNetwork
Password	string	A senha usada para conectar-se à instância RabbitMQ de código aberto.	yourPassword
QueueName	string	O nome da fila na instância RabbitMQ de código aberto.	demo
SecurityGroupId	string	O ID do grupo de segurança.	sg-m5edtu24f12345****
Username	string	O nome de usuário usado para conectar-se à instância RabbitMQ de código aberto.	admin
VSwitchIds	string	O ID do vSwitch.	vsw-m5ev8asdc6h12345****
VirtualHostName	string	O nome do host virtual na instância RabbitMQ de código aberto.	Vhost1
VpcId	string	O ID da VPC.	vpc-m5e3sv4b12345****
SourcePostgreSQLParameters	SourcePostgreSQLParameters	Os parâmetros de origem do PostgreSQL.
SourcePrometheusParameters	object	A origem de eventos Prometheus.
ClusterId	string	O ID do cluster.	c83555068b6******ad213f565f209
DataType	string	O tipo de dados.	JSON
ExternalLabels	string	Os rótulos personalizados anexados ao evento.	{"source":"prometheus-prod"}
Labels	string	A tag.	__name__=.*
RegionId	string	O ID da região.	cn-beijing
RoleName	string	A função RAM usada para acessar os dados do Prometheus.	testRole
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters	Os parâmetros de origem de metadados do Message Queue for RabbitMQ.
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters	Os parâmetros de origem de sincronização de mensagens do Message Queue for RabbitMQ.
SourceRabbitMQParameters	object	A origem de eventos ApsaraMQ for RabbitMQ.
InstanceId	string	O ID da instância do Message Queue for RabbitMQ.	dbaudit-cn-7mz2hqo****
QueueName	string	O nome da fila na instância do Message Queue for RabbitMQ.	liuyang
RegionId	string	O ID da região.	cn-zhangjiakou
VirtualHostName	string	O nome do host virtual na instância do Message Queue for RabbitMQ.	eb-connect
SourceRocketMQCheckpointParameters	object	A origem de checkpoint do Apache RocketMQ.
InstanceId	string	O ID da instância do Message Queue for RocketMQ.	rmq-cn-jte3w******
InstanceType	string	O tipo da instância do Message Queue for RocketMQ.	Cloud_5
RegionId	string	O ID da região.	cn-hangzhou
Topics	array	Os tópicos na instância do Message Queue for RocketMQ.
	string	Os tópicos na instância do Message Queue for RocketMQ.	myTopic
SourceRocketMQParameters	object	A fonte de eventos de origem do ApsaraMQ for RocketMQ.
AuthType	string	O tipo de autenticação.	ACL
BodyDataType	string	O formato de codificação da mensagem. Valores válidos: JSON Text Binary	JSON
FilterSql	string	A instrução de filtro SQL.	index > 10
FilterType	string	O tipo de filtragem de mensagens.	Tag
GroupID	string	O ID do grupo no Message Queue for RocketMQ.	GID_group1
InstanceEndpoint	string	O endpoint da instância.	registry-vpc.cn-hangzhou.aliyuncs.com
InstanceId	string	O ID da instância do Message Queue for RocketMQ.	i-f8zbher64dlm58pl****
InstanceNetwork	string	As informações de rede da instância. Valores válidos:\n- PublicNetwork\n- PrivateNetwork.	PublicNetwork
InstancePassword	string	A senha da instância.	123
InstanceSecurityGroupId	string	As informações do grupo de segurança da instância.	sg-m5edtu24f12345****
InstanceType	string	O tipo de instância. Valores válidos: Cloud_4: Instância do ApsaraMQ for RocketMQ 4.0 (padrão). Cloud_5: Instância do ApsaraMQ for RocketMQ 5.0. SelfBuilt: Cluster Apache RocketMQ autogerenciado.	Cloud_4
InstanceUsername	string	O nome de usuário da instância.	admin**
InstanceVSwitchIds	string	As informações de vSwitch da instância.	vsw-m5ev8asdc6h123456****
InstanceVpcId	string	O ID da VPC.	vpc-bp1a4gmlk31hy***l3ss
Network	string	O tipo de rede. Valores válidos:\n- PublicNetwork\n- PrivateNetwork.	PublicNetwork
Offset	string	O offset de consumo da mensagem. Valores válidos:\n- CONSUMEFROMLASTOFFSET: Consome mensagens a partir do offset mais recente.\n- CONSUMEFROMFIRSTOFFSET: Consome mensagens a partir do offset mais antigo.\n- CONSUMEFROMTIMESTAMP: Consome mensagens a partir do offset em um ponto específico no tempo.	CONSUMEFROMTIMESTAMP
RegionId	string	O ID da região do Message Queue for RocketMQ.	cn-chengdu
SecurityGroupId	string	O ID do grupo de segurança.	sg-m5edtu24f12345****
Tag	string	A tag de filtro da mensagem.	v1
Timestamp	integer	O carimbo de data e hora. Este parâmetro é válido apenas quando o parâmetro Offset é definido como CONSUMEFROMTIMESTAMP.	1670742074043
Topic	string	O tópico da mensagem.	topic_add_anima
VSwitchIds	string	Os IDs dos vSwitches.	vsw-m5ev8asdc6h12345****
VpcId	string	O ID da VPC.	vpc-m5e3sv4b12345****
SourceSLSParameters	object	A fonte de eventos de origem do SLS.
ConsumePosition	string	O offset de início de consumo. Você pode definir este parâmetro como begin para o offset mais antigo ou end para o offset mais recente. Você também pode especificar um ponto no tempo em segundos para iniciar o consumo.	begin
ConsumerGroup	string	O ID do grupo do consumidor que assina o tópico.	go-dts-shelf-group
LogStore	string	O Logstore do Simple Log Service (SLS).	waf-logstore
Project	string	O projeto do Simple Log Service (SLS).	dmmzk
RoleName	string	Ao conceder autorização ao barramento de eventos EventBridge para usar esta função para ler logs do Simple Log Service (SLS), você deve selecionar Alibaba Cloud Service como a entidade confiável e event bus como o serviço confiável ao criar a função no console do Resource Access Management (RAM).	testRole
Status	string	O status do fluxo de eventos.	RUNNING
Transforms	array<object>	As configurações de transformação.
	object	O ARN do serviço em nuvem, como o ARN de uma função no Function Compute.
AiChunkTransformParameters	AiChunkTransformParameters	Os parâmetros de fragmentação de texto local de IA.
AiClassifyTransformParameters	AiClassifyTransformParameters	Os parâmetros de classificação de texto de IA.
AiEmbedTransformParameters	AiEmbedTransformParameters	Os parâmetros de vetorização de IA.
AiExtractTransformParameters	AiExtractTransformParameters	Os parâmetros de extração de informações de IA.
AiFilterTransformParameters	AiFilterTransformParameters	Os parâmetros de filtragem condicional de IA.
AiPrepSearchTransformParameters	AiPrepSearchTransformParameters	Os parâmetros de fragmentação semântica de IA.
AiRedactTransformParameters	AiRedactTransformParameters	Os parâmetros de mascaramento de dados de IA.
AiSentimentAnalysisTransformParameters	AiSentimentAnalysisTransformParameters	Os parâmetros de análise de sentimentos de IA.
AiSummarizeTransformParameters	AiSummarizeTransformParameters	Os parâmetros de sumarização de IA.
AiTranslateTransformParameters	AiTranslateTransformParameters	Os parâmetros de tradução de IA.
Arn	string	O ARN do serviço em nuvem, como o ARN de uma função no Function Compute.	acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
BaiLianAgentTransformParameters	BaiLianAgentTransformParameters	Os parâmetros de transformação do agente do Model Studio.
DashScopeTransformParameters	DashScopeTransformParameters	Os parâmetros de transformação do modelo DashScope.
NextToken	string	O token que indica a posição onde a chamada atual para de ler. Um valor vazio indica que todos os dados foram lidos. Defina este valor como o parâmetro de solicitação NextToken na próxima chamada.	177
Total	integer	O número total de registros.	10
Message	string	A mensagem de erro.	The event streaming [xxxx] not existed!
RequestId	string	O ID da solicitação.	283FF852-C4B8-58C9-9777-F88A5A16****
Success	boolean	Indica se a operação foi bem-sucedida.	true

Exemplos

Resposta de sucesso

JSON formato

{
  "Code": "Success",
  "Data": {
    "EventStreamings": [
      {
        "Description": "demo",
        "EventStreamingName": "nome",
        "FilterPattern": "{\n\"source\": [\n{\n\"prefix\": \"acs:mns\"\n}\n],\n\"type\": [\n{\n\"prefix\": \"mns:Queue\"\n}\n],\n\"subject\": [\n{\n\"prefix\": \"acs:mns:cn-hangzhou:123456789098****:queues/zeus\"\n}\n]\n}",
        "Metadata": "{\"key\":\"value\"}",
        "RunOptions": {
          "BatchWindow": {
            "CountBasedWindow": 100,
            "TimeBasedWindow": 10
          },
          "BusinessOption": {
            "BusinessMode": "\"BusinessMode\"",
            "MaxCapacityUnitCount": 10,
            "MinCapacityUnitCount": 1
          },
          "DeadLetterQueue": {
            "Arn": "acs:ram::159787121179****:role/aliyunsaedefaultrole",
            "Network": "PrivateNetwork",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****",
            "VpcId": "vpc-2zehizpoendb3****"
          },
          "ErrorsTolerance": "ALL",
          "MaximumTasks": 2,
          "RetryStrategy": {
            "PushRetryStrategy": "EXPONENTIAL_DECAY_RETRY"
          },
          "Throttling": 100
        },
        "Sink": {
          "SinkAgentRunParameters": {
            "AgentRuntimeName": "",
            "EndpointName": "",
            "RoleName": "",
            "Body": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Timeout": ""
          },
          "SinkApacheRocketMQCheckpointParameters": {
            "ConsumeTimestamp": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "1636597951964"
            },
            "Group": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "GID_******"
            },
            "InstanceEndpoint": "192.168.1.1:9876",
            "InstancePassword": "****",
            "InstanceUsername": "admin",
            "NetworkType": "PrivateNetwork",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
            "Topic": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "myTopic"
            },
            "VSwitchId": "vsw-wz9qqeovkwjxlu9uc****",
            "VpcId": "vpc-2zehizpoendb3****"
          },
          "SinkApiDestinationParameters": {
            "Name": "",
            "HeaderParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "BodyParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "QueryStringParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Timeout": 0
          },
          "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": ""
            }
          },
          "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=rb8q3OpV2i3gZJ\"",
            "ConnectorParameters": {
              "Config": {
                "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
                "tasks.max": "1",
                "topics": "sourceA,sourceB"
              },
              "Name": "mongo-sink"
            },
            "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"
            }
          },
          "SinkCustomizedKafkaParameters": {
            "InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb2b71\n"
          },
          "SinkDashVectorParameters": {
            "ApiKey": "Q34nExQH7sQ****",
            "Collection": "collection1",
            "DashVectorSchemaParameters": [
              {
                "Name": {
                  "Form": "CONSTANT",
                  "Template": "模板字符串（如有）",
                  "Value": "content"
                },
                "Type": {
                  "Form": "CONSTANT",
                  "Template": "模板字符串（如有）",
                  "Value": "STRING"
                },
                "Value": {
                  "Form": "JSONPATH",
                  "Template": "${content}",
                  "Value": "$.data.content"
                }
              }
            ],
            "InstanceId": "vrs-cn-lbj3ru1***",
            "Network": "PublicNetwork",
            "Operation": "Upsert",
            "Partition": {
              "Form": "CONSTANT",
              "Template": "${partition}",
              "Value": "default"
            },
            "PrimaryKeyId": {
              "Form": "JSONPATH",
              "Template": "${ID}\n",
              "Value": "$.data.requestId"
            },
            "Vector": {
              "Form": "JSONPATH",
              "Template": "${vector}",
              "Value": "$.data.messageBody"
            }
          },
          "SinkDataHubParameters": {
            "Body": {
              "Form": "ORIGINAL",
              "Template": "模板字符串（如有）",
              "Value": "{\n  \"key\": \"value\"\n}"
            },
            "Project": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "demo-project"
            },
            "RoleName": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "testRole"
            },
            "Topic": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "demo-topic"
            },
            "TopicSchema": {
              "Form": "CONSTANT",
              "Template": "{\"k1\":\"${k1}\",\"k2\":\"${k2}\"}",
              "Value": "{\"k1\":\"value1\",\"k2\":\"value2\"}"
            },
            "TopicType": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "TUPLE"
            }
          },
          "SinkDorisParameters": {
            "BeHttpEndpoint": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "\"BeHttpEndpoint\""
            },
            "Body": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "{\n  \"key\": \"value\"\n}"
            },
            "Database": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "\"Database\""
            },
            "FeHttpEndpoint": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "\"FeHttpEndpoint\""
            },
            "NetworkType": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "PublicNetwork"
            },
            "Password": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "yourPassword"
            },
            "QueryEndpoint": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "\"QueryEndpoint\""
            },
            "SecurityGroupId": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "sg-mw43*****"
            },
            "Table": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "\"Table\""
            },
            "UserName": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "\"UserName\""
            },
            "VSwitchIds": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "vbr-8vb835n3zf9shwl****mp\n"
            },
            "VpcId": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "i-2ze7u5i17mbqtx1p****"
            }
          },
          "SinkEventHouseParameters": {
            "CatalogName": "cat1",
            "EventTableName": "table1",
            "MappingRules": [
              {
                "ColumnName": "age",
                "ColumnType": "text",
                "ColumnValue": {
                  "Form": "JSONPATH",
                  "Template": "O valor de ${key} é ${value}!",
                  "Value": "$.data.value"
                }
              }
            ],
            "NamespaceName": "name1"
          },
          "SinkFcParameters": {
            "Body": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Concurrency": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "1"
            },
            "DataFormat": {
              "Form": "CONSTANT",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "FunctionName": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "mFunction"
            },
            "InvocationType": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "Async"
            },
            "Qualifier": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "LATEST"
            },
            "ServiceName": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "myService"
            }
          },
          "SinkFnfParameters": {
            "ExecutionName": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "123"
            },
            "FlowName": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "test-streaming-fnf"
            },
            "Input": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "123"
            },
            "RoleName": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "Al****FNF-x****"
            }
          },
          "SinkHttpsParameters": {
            "URL": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Method": "",
            "Body": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Token": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": ""
          },
          "SinkKafkaParameters": {
            "Acks": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "1"
            },
            "CompressionType": "\"CompressionType\"",
            "DynamicTopic": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "\"DynamicTopic\""
            },
            "InstanceId": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "Defaut_1283278472_sad****"
            },
            "Key": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "key"
            },
            "Topic": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "topic"
            },
            "Value": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            }
          },
          "SinkKnowledgeBaseParameters": {
            "Catalog": "my_catalog",
            "KnowledgeBaseName": "my-knowledge-base",
            "Namespace": "my_namespace"
          },
          "SinkMNSParameters": {
            "Body": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "IsBase64Encode": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "true"
            },
            "QueueName": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "MyQueue"
            }
          },
          "SinkMQTTParameters": {
            "InstanceId": "",
            "ParentTopic": "",
            "SubTopic": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Payload": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Mqtt5UserProperty": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          },
          "SinkOSSParameters": {
            "BucketName": "",
            "RegionId": "",
            "Endpoint": "",
            "RoleArn": "",
            "RotateSizeBytes": "",
            "RotateIntervalMs": "",
            "PathFormat": "",
            "CompressionType": "",
            "TaskConcurrency": "",
            "TimeZone": "",
            "SSLEnabled": false,
            "ContentTransform": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          },
          "SinkOpenSourceRabbitMQParameters": {
            "AuthType": "ACL",
            "Body": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Endpoint": "192.168.1.1:9876",
            "Exchange": "my_exchange",
            "MessageId": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "NetworkType": "PrivateNetwork",
            "Password": "****",
            "Properties": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "\t\n{\n      \"key\": \"value\"\n}"
            },
            "QueueName": "my_queue",
            "RoutingKey": {
              "Form": "JSONPATH",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "housekeeping"
            },
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
            "TargetType": "exchange",
            "Username": "admin",
            "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc****",
            "VirtualHostName": "Vhost1",
            "VpcId": "vpc-2zehizpoendb3****"
          },
          "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": ""
          },
          "SinkRabbitMQParameters": {
            "Body": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Exchange": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "a_exchange"
            },
            "InstanceId": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "si-296cd57939a1421b****"
            },
            "MessageId": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Properties": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "QueueName": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "MyQueue"
            },
            "RoutingKey": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "housekeeping"
            },
            "TargetType": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "Queue"
            },
            "VirtualHostName": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "rabbit-host"
            }
          },
          "SinkRocketMQCheckpointParameters": {
            "ConsumeTimestamp": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "1636597951964"
            },
            "Group": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "GID_******"
            },
            "InstanceId": "MQ_INST_1825725063814405_BZ******",
            "InstanceType": "Cloud_5",
            "Topic": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "myTopic"
            }
          },
          "SinkRocketMQParameters": {
            "Body": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "DeliveryOrderType": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "Orderly"
            },
            "InstanceEndpoint": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "vbr-8vbsvkkbpf3vb0zef****"
            },
            "InstanceId": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "MQ_INST_164901546557****_BAAN****"
            },
            "InstancePassword": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "admin******"
            },
            "InstanceType": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "Cloud_4"
            },
            "InstanceUsername": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "admin"
            },
            "Keys": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Network": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "PublicNetwork"
            },
            "Properties": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "SecurityGroupId": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "b4bf375515f6440f942e3a20c33d****\n"
            },
            "ShardingKey": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "order_id"
            },
            "Tags": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Topic": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "topic"
            },
            "VSwitchIds": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "vbr-8vb835n3zf9shwl****mp"
            },
            "VpcId": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "vbr-8vb835n3zf9shwlvb****"
            }
          },
          "SinkSLSParameters": {
            "Body": {
              "Form": "TEMPLATE",
              "Template": "O valor de ${key} é ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "ContentSchema": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "{\"Key_1\":{\"form\":\"CONSTANT\",\"value\":\"demoKey\"},\"Value_1\":{\"form\":\"JSONPATH\",\"value\":\"$.data.value\"}}"
            },
            "ContentType": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "JSON"
            },
            "LogStore": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "test-logstore"
            },
            "Project": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "test-project"
            },
            "RoleName": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "test-role"
            },
            "Topic": {
              "Form": "CONSTANT",
              "Template": "模板字符串（如有）",
              "Value": "topic"
            }
          }
        },
        "Source": {
          "SourceApacheRocketMQCheckpointParameters": {
            "InstanceEndpoint": "192.168.1.1:9876",
            "InstancePassword": "****",
            "InstanceUsername": "admin",
            "NetworkType": "PrivateNetwork",
            "RegionId": "cn-hangzhou",
            "SecurityGroupId": "sg-mw43*****",
            "Topics": [
              "myTopic"
            ],
            "VSwitchId": "vsw-dwaafds****",
            "VpcId": "vpc-adw1awdw*****"
          },
          "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": {
              "Config": {
                "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
                "tasks.max": "1",
                "topics": "sourceA,sourceB"
              },
              "Name": "test-name"
            },
            "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"
            }
          },
          "SourceCustomizedKafkaParameters": {
            "InstanceId": "gtm-cn-k2c2yfg****"
          },
          "SourceDTSParameters": {
            "BrokerUrl": "\"BrokerUrl\"",
            "InitCheckPoint": "1620962769",
            "Password": "123456",
            "Sid": "HG9",
            "TaskId": "1611b337285f44e2936a2c4170****",
            "Topic": "TP_TEST_UNDERWRITE_ISSUE",
            "Username": "admin"
          },
          "SourceEventBusParameters": {
            "EventBusName": "my-event-bus",
            "EventRuleName": "my-event-rule"
          },
          "SourceFeiShuDocsParameters": {
            "AppId": "cli_a946c046xxxx",
            "AppSecret": "yO3hEYiSjkBVxxxx",
            "KnowledgeSpaceName": "Centro de Documentação do Produto",
            "LoadMode": "single"
          },
          "SourceJDBCParameters": {
            "JdbcUrl": "",
            "Username": "",
            "Password": "",
            "QueryMode": "",
            "TableName": "",
            "IncrementingColumn": "",
            "TimestampColumn": "",
            "PollingInterval": 0,
            "BatchSize": 0,
            "QueryTimeout": 0,
            "CustomQuery": "",
            "Network": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": ""
          },
          "SourceKafkaParameters": {
            "ConsumerGroup": "GID_TEST",
            "InstanceId": "bastionhost-cn-i7m2gwt****",
            "Network": "Default",
            "OffsetReset": "latest",
            "RegionId": "cn-chengdu",
            "SecurityGroupId": "sg-5ud5f3p0rqqis69****eho7cp",
            "Topic": "topic_empower_1642473600414",
            "VSwitchIds": "vsw-bp1rmi8rind7eo50c****",
            "ValueDataType": "JSON",
            "VpcId": "vpc-wz9ki1qdlx3cx5cbf****"
          },
          "SourceMNSParameters": {
            "IsBase64Decode": true,
            "QueueName": "work4",
            "RegionId": "cn-zhangjiakou"
          },
          "SourceMQTTParameters": {
            "BodyDataType": "JSON",
            "InstanceId": "bastionhost-cn-zvp27kc****",
            "NetworkType": "PrivateNetwork",
            "RegionId": "cn-qingdao",
            "SecurityGroupId": "sg-bp1iv19sp1msc7zot4****",
            "Topic": "migration_instance",
            "VSwitchIds": "vsw-bp179l3llg3jjxwrq72****",
            "VpcId": "vpc-8vblalsi0vbhizr77****"
          },
          "SourceMySQLParameters": {
            "RegionId": "",
            "HostName": "",
            "User": "",
            "Password": "",
            "DatabaseName": "",
            "TableNames": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "Port": 0,
            "SnapshotMode": "",
            "IncludeSchemaChanges": ""
          },
          "SourceOSSParameters": {
            "BucketName": "bucket_abc",
            "Delimiter": "\\n\n",
            "LoadFormat": "TextLoader",
            "LoadMode": "single",
            "Prefix": "fun/document/",
            "RoleName": "eventbridge_oss_role"
          },
          "SourceOpenSourceRabbitMQParameters": {
            "AuthType": "ACL",
            "BodyDataType": "Json",
            "Endpoint": "192.168.1.1:9876",
            "NetworkType": "PrivateNetwork",
            "Password": "****",
            "QueueName": "demo",
            "SecurityGroupId": "sg-m5edtu24f12345****",
            "Username": "admin",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****",
            "VirtualHostName": "Vhost1",
            "VpcId": "vpc-m5e3sv4b12345****"
          },
          "SourcePostgreSQLParameters": {
            "RegionId": "",
            "HostName": "",
            "Port": 0,
            "User": "",
            "Password": "",
            "DatabaseName": "",
            "SchemaName": "",
            "TableNames": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "SnapshotMode": ""
          },
          "SourcePrometheusParameters": {
            "ClusterId": "c83555068b6******ad213f565f209\n",
            "DataType": "JSON",
            "ExternalLabels": "{\"source\":\"prometheus-prod\"}",
            "Labels": "__name__=.*",
            "RegionId": "cn-beijing",
            "RoleName": "testRole"
          },
          "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": ""
          },
          "SourceRabbitMQParameters": {
            "InstanceId": "dbaudit-cn-7mz2hqo****",
            "QueueName": "liuyang",
            "RegionId": "cn-zhangjiakou",
            "VirtualHostName": "eb-connect"
          },
          "SourceRocketMQCheckpointParameters": {
            "InstanceId": "\nrmq-cn-jte3w******",
            "InstanceType": "Cloud_5",
            "RegionId": "cn-hangzhou",
            "Topics": [
              "myTopic"
            ]
          },
          "SourceRocketMQParameters": {
            "AuthType": "ACL",
            "BodyDataType": "JSON",
            "FilterSql": "index > 10",
            "FilterType": "Tag",
            "GroupID": "GID_group1",
            "InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
            "InstanceId": "i-f8zbher64dlm58pl****",
            "InstanceNetwork": "PublicNetwork",
            "InstancePassword": "123",
            "InstanceSecurityGroupId": "sg-m5edtu24f12345****",
            "InstanceType": "Cloud_4",
            "InstanceUsername": "admin**",
            "InstanceVSwitchIds": "vsw-m5ev8asdc6h123456****",
            "InstanceVpcId": "vpc-bp1a4gmlk31hy***l3ss",
            "Network": "PublicNetwork",
            "Offset": "CONSUMEFROMTIMESTAMP",
            "RegionId": "cn-chengdu",
            "SecurityGroupId": "sg-m5edtu24f12345****",
            "Tag": "v1",
            "Timestamp": 1670742074043,
            "Topic": "topic_add_anima",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****",
            "VpcId": "vpc-m5e3sv4b12345****"
          },
          "SourceSLSParameters": {
            "ConsumePosition": "begin",
            "ConsumerGroup": "go-dts-shelf-group",
            "LogStore": "waf-logstore",
            "Project": "dmmzk",
            "RoleName": "testRole"
          }
        },
        "Status": "RUNNING",
        "Transforms": [
          {
            "AiChunkTransformParameters": {
              "ChunkingType": "recursive_character",
              "InputField": {
                "Form": "JSONPATH",
                "Value": "$.data.message"
              },
              "MaxOverlapSize": 10,
              "MaxSegmentSize": 1000,
              "StepName": "chunks",
              "Unpack": true
            },
            "AiClassifyTransformParameters": {
              "InputField": {
                "Form": "JSONPATH",
                "Value": "$.data.message"
              },
              "Instruction": "Classifique como bug quando falha ou exceção for mencionada, classifique como outro em caso de incerteza",
              "Labels": [
                "bug"
              ],
              "OutputMode": "single",
              "StepName": "classify_result"
            },
            "AiEmbedTransformParameters": {
              "Dimension": 1024,
              "InputField": {
                "Form": "JSONPATH",
                "Value": "$.data.message"
              },
              "Model": "text-embedding-v4",
              "StepName": "embedding"
            },
            "AiExtractTransformParameters": {
              "ExtractSchema": "{\"type\":\"object\",\"properties\":{\"orderId\":{\"type\":\"string\"},\"amount\":{\"type\":\"number\"}}}",
              "StepName": "extract_result"
            },
            "AiFilterTransformParameters": {
              "Condition": "Reter apenas conteúdo relacionado a reclamações ou reembolsos de usuários",
              "OnMismatch": "discard",
              "StepName": "filter_result"
            },
            "AiPrepSearchTransformParameters": {
              "MaxChunkSize": 20,
              "StepName": "fragmentos"
            },
            "AiRedactTransformParameters": {
              "Entities": [
                "PHONE"
              ],
              "MaskChar": "*",
              "Mode": "mask",
              "StepName": "redact_result"
            },
            "AiSentimentAnalysisTransformParameters": {
              "Aspects": [
                "preço"
              ],
              "StepName": "sentimento"
            },
            "AiSummarizeTransformParameters": {
              "MaxLength": 200,
              "StepName": "resumo"
            },
            "AiTranslateTransformParameters": {
              "SourceLanguage": "zh",
              "StepName": "tradução",
              "TargetLanguage": "en"
            },
            "Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func",
            "BaiLianAgentTransformParameters": {
              "ApplicationId": "",
              "Prompt": {
                "Form": "",
                "Value": "",
                "Template": ""
              },
              "ApiKey": "",
              "RequestPerMinute": 0,
              "TokenPerMinute": 0
            },
            "DashScopeTransformParameters": {
              "Model": "",
              "ApiKey": "",
              "StructuredOutputJsonSchema": "",
              "RequestPerMinute": 0,
              "TokenPerMinute": 0,
              "Messages": [
                {
                  "Role": "",
                  "Form": "",
                  "Value": "",
                  "Template": ""
                }
              ]
            }
          }
        ]
      }
    ],
    "NextToken": "177",
    "Total": 10
  },
  "Message": "O event streaming [xxxx] não existe!",
  "RequestId": "283FF852-C4B8-58C9-9777-F88A5A16****",
  "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.