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

Modifica as informações básicas, as informações da origem do evento, o padrão de filtragem de eventos ou as informações do destino do evento de um fluxo de eventos.

Descrição da operação

Modifica as informações básicas, as informações da origem do evento, o padrão de filtragem de eventos ou as informações do destino do evento 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:UpdateEventStreaming

update

*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.	myeventstreaming.
Description	string	Não	A descrição do fluxo de eventos.	rocketmq2mns.
FilterPattern	string	Não	A regra de filtragem de eventos. Se você não especificar este parâmetro, todos os eventos serão correspondidos. Para mais informações, consulte https://www.alibabacloud.com/help/en/eventbridge/user-guide/event-patterns	{ "source": [ { "prefix": "acs:mns" } ], "type": [ { "prefix": "mns:Queue" } ], "subject": [ { "prefix": "acs:mns:cn-hangzhou:123456789098****:queues/zeus" } ] }
Source	object	Não	O provedor de eventos. Você deve selecionar um e apenas um tipo de Origem.
SourceMNSParameters	object	Não	A origem Simple Message Queue (anteriormente MNS).
RegionId	string	Não	O ID da região.	cn-hangzhou.
QueueName	string	Não	O nome da fila.	queue_api_1642474203601
IsBase64Decode	boolean	Não	Especifica se a decodificação Base64 deve ser ativada. Valor padrão: true.	true.
SourceRabbitMQParameters	object	Não	A origem RabbitMQ.
RegionId	string	Não	O ID da região.	cn-hangzhou.
InstanceId	string	Não	O ID da instância do ApsaraMQ for RabbitMQ.	i-f8z9lqkldlb4oxsxwwub.
VirtualHostName	string	Não	O nome do vhost da instância do ApsaraMQ for RabbitMQ.	eb-connect.
QueueName	string	Não	O nome da fila da instância do ApsaraMQ for RabbitMQ.	demo.
SourceKafkaParameters	object	Não	A origem Kafka.
RegionId	string	Não	O ID da região.	cn-zhangjiakou.
InstanceId	string	Não	O ID da instância.	i-8vbh4a5b9yfhgkkzm****
Topic	string	Não	O nome do tópico.	topic_empower_1641539400786
ConsumerGroup	string	Não	O Group ID do consumidor que assina o tópico.	DEFAULT_GROUP.
OffsetReset	string	Não	O offset.	latest.
Network	string	Não	A configuração de rede. Valor padrão: Default. Defina como PublicNetwork para redes VPC.	Default.
VpcId	string	Não	O ID da nuvem privada virtual (VPC).	vpc-2ze6p0o345nykmekxt****
VSwitchIds	string	Não	O ID do vSwitch.	vsw-wz9t1l1e8eu2om****
SecurityGroupId	string	Não	O ID do grupo de segurança.	sg-uf6jcm3y5hcs7hkl****
ValueDataType	string	Não	O método de codificação e decodificação. Valores válidos: Json: decodifica bytes em uma string usando codificação UTF-8 e analisa a string no formato JSON. Text: decodifica bytes em uma string usando codificação UTF-8 e coloca a string diretamente no payload. Binary: codifica bytes em uma string usando codificação Base64 e coloca a string no payload.	Text.
SourceRocketMQParameters	object	Não	A origem RocketMQ.
RegionId	string	Não	O ID da região da instância do ApsaraMQ for RocketMQ.	cn-shanghai.
InstanceId	string	Não	O ID da instância do ApsaraMQ for RocketMQ.	i-f8z9a9mcgwri1c1id****
Topic	string	Não	O nome do tópico.	TOPIC-cainiao-pcs-order-process-inBoundConditionCheck.
Tag	string	Não	A tag de filtro da mensagem.	test.
Offset	string	Não	O offset de consumo da mensagem. Valores válidos: CONSUMEFROMLASTOFFSET: O consumo começa a partir do offset mais recente. CONSUMEFROMFIRSTOFFSET: O consumo começa a partir do offset mais antigo. CONSUMEFROMTIMESTAMP: O consumo começa a partir do offset no horário especificado. Valor padrão: CONSUMEFROMLAST_OFFSET.	CONSUMEFROMLASTOFFSET.
GroupID	string	Não	O group ID da instância do ApsaraMQ for RocketMQ.	GID_test.
Timestamp	integer	Não	O timestamp. Este parâmetro é válido apenas quando o parâmetro Offset está definido como CONSUMEFROMTIMESTAMP.	1670656652009
InstanceType	string	Não	O tipo de instância. Valores válidos: Cloud_4 (padrão): Instância do Alibaba Cloud RocketMQ 4.0 Cloud_5: Instância do Alibaba Cloud RocketMQ 5.0 SelfBuilt: Instância auto-gerenciada do Apache RocketMQ	Cloud_5
InstanceEndpoint	string	Não	O endpoint da instância.	reg****-vpc.cn-zhangjiakou.aliyuncs.com.
InstanceUsername	string	Não	O nome de usuário da instância.	admin.
InstancePassword	string	Não	A senha da instância.	admin.
AuthType	string	Não	O tipo de autenticação.	ACL.
InstanceVpcId	string	Não	As informações de VPC da instância.	vpc-m5e3sv4b12345****
InstanceVSwitchIds	string	Não	As informações de vSwitch da instância.	vsw-m5ev8asdc6h12****
InstanceSecurityGroupId	string	Não	As informações de grupo de segurança da instância.	sg-m5edtu24f12345****
InstanceNetwork	string	Não	As informações de rede da instância. Valores válidos: PublicNetwork PrivateNetwork	PublicNetwork.
BodyDataType	string	Não	O formato de codificação da mensagem. Valores válidos: Json Text Binary	Json.
FilterType	string	Não	O tipo de filtro de mensagem.	Tag.
FilterSql	string	Não	A instrução de filtro SQL.	index > 10
VpcId	string	Não	O ID da VPC da instância.	vpc-m5e3sv4b12345****
VSwitchIds	string	Não	O ID do vSwitch.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	Não	O ID do grupo de segurança.	sg-m5edtu24f12345****
Network	string	Não	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork	PublicNetwork.
SourceRocketMQCheckpointParameters	object	Não	A origem de Checkpoint RocketMQ.
RegionId	string	Não	O ID da região.	cn-hangzhou.
InstanceType	string	Não	O tipo da instância do ApsaraMQ for RocketMQ.	Cloud_5
InstanceId	string	Não	O ID da instância do ApsaraMQ for RocketMQ.	rmq-cn-jte3w******
Topics	array	Não	O tópico da instância do ApsaraMQ for RocketMQ.
	string	Não	O tópico da instância do ApsaraMQ for RocketMQ.	myTopic.
SourceApacheRocketMQCheckpointParameters	object	Não	A origem de Checkpoint RocketMQ.
RegionId	string	Não	O ID da região.	cn-hangzhou.
Topics	array	Não	O tópico da instância do Apache RocketMQ.
	string	Não	O tópico da instância do Apache RocketMQ.	myTopic.
InstanceEndpoint	string	Não	O endpoint da instância do Apache RocketMQ.	192.168.1.1:9876
InstanceUsername	string	Não	O nome de usuário da instância do Apache RocketMQ.	admin.
InstancePassword	string	Não	A senha da instância do Apache RocketMQ.	****
NetworkType	string	Não	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork	PrivateNetwork.
VpcId	string	Não	O ID da VPC.	vpc-adw1awdw*****
VSwitchId	string	Não	O ID do vSwitch.	vsw-dwaafds****
SecurityGroupId	string	Não	O ID do grupo de segurança.	sg-mw43*****
SourceMQTTParameters	object	Não	A origem MQTT.
RegionId	string	Não	O ID da região.	cn-shanghai.
InstanceId	string	Não	O ID da instância.	i-bp1dsudbecqwt61j****
Topic	string	Não	O nome do tópico.	topic_empower_1642400400779
BodyDataType	string	Não	O formato de codificação da mensagem. Valores válidos: JSON Text Binary	JSON.
NetworkType	string	Não	O tipo de rede.
VpcId	string	Não	O ID da VPC.
VSwitchIds	string	Não	O ID do vSwitch.
SecurityGroupId	string	Não	O ID do grupo de segurança.
SourceDTSParameters	object	Não	A origem DTS.
TaskId	string	Não	O ID da tarefa.	f86e5814-b223-482c-b768-3b873297****
BrokerUrl	string	Não	O endereço de rede e o número da porta do canal de assinatura de dados.
Topic	string	Não	O tópico de assinatura do canal de assinatura de dados.	LTC_CACHE_PRD.
Sid	string	Não	O ID do grupo de consumidores.	hkprdb.
Username	string	Não	A conta do grupo de consumidores.	admin.
Password	string	Não	A senha da conta do grupo de consumidores.	admin.
InitCheckPoint	integer	Não	O offset de consumo, que é o timestamp em que o cliente SDK consome o primeiro registro de dados. O valor é um timestamp UNIX.	1620962769
SourceSLSParameters	object	Não	A origem SLS.
RoleName	string	Não	O nome da função usada para autorização para permitir que o barramento de eventos EventBridge leia o conteúdo de logs do Simple Log Service. Ao criar a função no console Resource Access Management (RAM), selecione "Alibaba Cloud Service" e defina "Trusted Service" como "event bus".	testRole.
SourcePrometheusParameters	object	Não	A origem de eventos Prometheus.
RegionId	string	Não	O ID da região da instância.	cn-hangzhou.
ClusterId	string	Não	O ID do cluster.	c83555068b6******ad213f565f209
DataType	string	Não	O tipo de dados.	Json.
Labels	string	Não	Os rótulos.	__name__=.*
RoleName	string	Não	O nome da função da tarefa.	test-role.
ExternalLabels	string	Não	Os rótulos externos anexados ao fluxo de eventos.	{"env":"test"}
SourceCustomizedKafkaParameters	object	Não	A origem de eventos Kafka personalizada.
InstanceId	string	Não	O ID da instância do ApsaraMQ for Kafka.	r-8vb64581862c****
SourceCustomizedKafkaConnectorParameters	object	Não	A origem de eventos Apache Kafka com conector personalizado.
ConnectorPackageUrl	string	Não	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	Não	Os parâmetros do conector.
Name	string	Não	O nome do conector.	test-name
Config	object	Não	A configuração do conector.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
WorkerParameters	object	Não	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	Não
Bootstraps	string	Não
SslKeystoreCertificateChain	string	Não	[Obrigatório para autenticação mútua] A cadeia de certificados do cliente Kafka. Este parâmetro é obrigatório quando o servidor Kafka ativa a autenticação SSL mútua (ssl.client.auth=required). Formato: formato PEM codificado em Base64 contendo o certificado do cliente e a cadeia completa de certificados (certificado do cliente primeiro, certificado da CA intermediária em seguida, certificado da CA raiz opcional). Nota: garanta que o conteúdo de cada arquivo PEM comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----', então codifique o conteúdo concatenado em Base64.
SslKeyPassword	string	Não	[Obrigatório para chave privada criptografada] A senha da chave privada do cliente Kafka. Este parâmetro é obrigatório quando a chave privada do cliente é protegida por senha (o arquivo PEM contém marcadores 'Proc-Type: 4,ENCRYPTED' ou 'ENCRYPTED'). Deixe em branco se a chave privada não estiver criptografada. Nota: esta senha é usada apenas para descriptografar a chave privada e não está relacionada à autenticação do Kafka.
SslTruststoreCertificates	string	Não	[Obrigatório para SSL] O certificado confiável do servidor Kafka. Usado para autenticar a validade do certificado SSL do Broker Kafka e prevenir ataques man-in-the-middle. Formato: Codificação Base64 do formato PEM, tipicamente contendo o certificado da CA ou o certificado do servidor do servidor Kafka. Exemplo: Codifique em Base64 o conteúdo do arquivo PEM do certificado da CA (garanta que o conteúdo comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----'). Se o Kafka usar um certificado autoassinado, forneça o certificado da CA que emitiu o certificado.
SslKeystoreKey	object	Não	[Obrigatório para autenticação bidirecional] O objeto de configuração da chave privada SSL. Quando o servidor Kafka ativa a autenticação SSL bidirecional, você deve fornecer a chave privada do cliente. Apenas o padrão KMS é suportado para a chave: especifique o recurso Key Management EPS que armazena a chave privada usando KmsArn. O sistema recupera o conteúdo da chave privada do KMS apenas na memória, o que fornece maior segurança. Exemplo de configuração: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}\n"
KmsArn	string	Não	[Obrigatório] O ARN do recurso KMS que armazena a chave privada SSL. Usado para localizar a instância do Key Management Service que armazena a chave privada do cliente. Exemplo de formato: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. Obtenha este valor nas informações de ARN da chave correspondente no console KMS.
KmsSecretValueKey	string	Não	[Modo KMS KV] O nome da chave na credencial KMS. Quando a credencial KMS é armazenada como uma estrutura chave-valor (KV), especifique este parâmetro para indicar a chave correspondente à chave privada SSL. Exemplo: se a credencial KMS for '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', insira 'ssl_keystore_key'. Deixe em branco se a credencial KMS estiver no modo de texto simples (armazena diretamente o conteúdo PEM da chave privada).
Topic	string	Não
ConsumerGroup	string	Não
OffsetReset	string	Não
ValueDataType	string	Não
VpcId	string	Não
VSwitchIds	string	Não
SecurityGroupId	string	Não
NetworkType	string	Não
SecurityProtocol	string	Não
SaslMechanism	string	Não
SaslUser	string	Não
SaslPassword	string	Não
SourceOSSParameters	object	Não	A origem de eventos OSS.
RoleName	string	Não	O nome da função usada para autorização para permitir que o barramento de eventos EventBridge leia arquivos do OSS. A função deve ter pelo menos permissões de somente leitura no OSS.	eventbridge_oss_role.
BucketName	string	Não	O nome do bucket no Object Storage Service (OSS).	bucket_abc.
Prefix	string	Não	O prefixo do caminho do arquivo.	fun/document/
LoadMode	string	Não	O modo de carregamento de dados. Valores válidos: single (carregamento de documento único) e element (carregamento fragmentado). Valor padrão: single.	single.
LoadFormat	string	Não	O carregador de documentos.	TextLoader.
Delimiter	string	Não	O delimitador. No modo de carregamento fragmentado, este delimitador é usado como identificador de fragmentação de texto. O delimitador padrão é o caractere de nova linha \n.	\n
SourceEventBusParameters	object	Não	A origem EventBus.
EventBusName	string	Não	O nome do barramento de eventos.	my-event-bus.
EventRuleName	string	Não	O nome da regra de evento.	my-event-rule.
SourceOpenSourceRabbitMQParameters	object	Não	A origem RabbitMQ Open Source.
Endpoint	string	Não	O endpoint da instância.	192.168.1.1:9876
VirtualHostName	string	Não	O nome do host virtual da instância RabbitMQ open source.	Vhost1
QueueName	string	Não	O nome da fila da instância RabbitMQ open source.	demo.
BodyDataType	string	Não	O tipo de dados do corpo da mensagem.	Json.
Username	string	Não	O nome de usuário usado para conectar à instância RabbitMQ open source.	admin.
Password	string	Não	A senha usada para conectar à instância RabbitMQ open source.	****
VpcId	string	Não	O ID da VPC.	vpc-m5e3sv4b12345****
VSwitchIds	string	Não	O ID do vSwitch.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	Não	O ID do grupo de segurança.	sg-m5edtu24f12345****
NetworkType	string	Não	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork	PrivateNetwork.
AuthType	string	Não	O tipo de autenticação.	ACL.
SourceMySQLParameters	SourceMySQLParameters	Não	A origem MySQL.
SourcePostgreSQLParameters	SourcePostgreSQLParameters	Não
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters	Não
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters	Não
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters	Não
SourceJDBCParameters	SourceJDBCParameters	Não
Metadata	string	Não
Sink	object	Não	O destino do evento. Você deve selecionar um e apenas um tipo de Sink.
SinkMNSParameters	object	Não	O destino de eventos Simple Message Queue (anteriormente MNS).
QueueName	object	Não	O tipo de serviço de destino é Simple Message Queue (anteriormente MNS).
Value	string	Não	O nome da fila no Simple Message Queue (anteriormente MNS).	MyQueue
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Body	object	Não	O conteúdo da mensagem.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
IsBase64Encode	object	Não	Especifica se a codificação Base64 deve ser ativada.
Value	string	Não	Especifica se a codificação Base64 deve ser ativada.	true
Form	string	Não	O formato de transformação de evento. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
SinkEventHouseParameters	object	Não	O nome do destino do evento.
CatalogName	string	Não	O nome do catálogo.	demo.
NamespaceName	string	Não	O namespace da tabela de destino.	name1
EventTableName	string	Não	O nome da tabela de destino.	demo-table.
MappingRules	array<object>	Não	As regras de mapeamento de campos.
	array<object>	Não	As regras de mapeamento de campos.
ColumnValue	object	Não	A regra de extração de valor de coluna.
Value	string	Não	O caminho de extração, como $.data.value.name.	$.data.value
Form	string	Não	O método de transformação, como JSONPATH.	JSONPATH
Template	string	Não	A configuração do modelo.	The value of ${key} is ${value}!
ColumnName	string	Não	O nome da coluna.	age
ColumnType	string	Não	O tipo da coluna.	text
SinkFcParameters	object	Não	O destino de função.
ServiceName	object	Não	O nome do serviço.
Value	string	Não	O nome do serviço.	myService
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
FunctionName	object	Não	O nome da função.
Value	string	Não	O nome da função.	mFunction
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Concurrency	object	Não	A concorrência de entrega. Valor mínimo: 1.
Value	string	Não	A concorrência de entrega. Valor mínimo: 1.	1
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Qualifier	object	Não	O alias do serviço ao qual a função pertence.
Value	string	Não	O alias do serviço ao qual a função pertence.	LATEST
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
InvocationType	object	Não	O tipo de invocação. Valores válidos: Sync: síncrono. Async: assíncrono.
Value	string	Não	O tipo de invocação.	Async
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Body	object	Não	O corpo de conteúdo enviado para a função.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
DataFormat	object	Não	A regra de conversão de formato para o conteúdo do evento.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação. Valores válidos: ORIGINAL: evento completo JSONPATH: evento parcial CONSTANT: constante TEMPLATE: modelo	JSONPATH
Template	string	Não	O estilo do modelo.	$.data.key
SinkRabbitMQParameters	object	Não	Os parâmetros do Sink RabbitMQ.
InstanceId	object	Não	O tipo de serviço de destino é ApsaraMQ for RabbitMQ.
Value	string	Não	O ID da instância MSMQ for RabbitMQ.	amqp-cn-2r42e73o****
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
VirtualHostName	object	Não	O nome do vhost da instância do ApsaraMQ for RabbitMQ.
Value	string	Não	O nome do vhost da instância MSMQ for RabbitMQ.	rabbit-host
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
TargetType	object	Não	O tipo de destino.
Value	string	Não	O tipo de destino. Valores válidos: Exchange: Modo Exchange. Queue: Modo Queue.	Exchange/Queue
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Exchange	object	Não	O modo Exchange. Este parâmetro é obrigatório apenas quando TargetType está definido como Exchange.
Value	string	Não	O nome do exchange da instância MSMQ for RabbitMQ.	a_exchange
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
RoutingKey	object	Não	A regra de roteamento da mensagem. Este parâmetro é obrigatório apenas quando TargetType está definido como Exchange.
Value	string	Não	A regra de roteamento da mensagem.	housekeeping
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
QueueName	object	Não	O modo Queue. Este parâmetro é obrigatório apenas quando TargetType está definido como Queue.
Value	string	Não	O nome da fila da instância.	MyQueue
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Body	object	Não	O conteúdo da mensagem.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
MessageId	object	Não	O ID da mensagem.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
Properties	object	Não	As propriedades de filtro.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
SinkKafkaParameters	object	Não	Os parâmetros do Sink Kafka.
InstanceId	object	Não	O tipo de serviço de destino é ApsaraMQ for Kafka.
Value	string	Não	O ID da instância.	Defaut_1283278472_s****
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
CompressionType	string	Não
Topic	object	Não	O nome do tópico.
Value	string	Não	O nome do tópico.	test
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
DynamicTopic	object	Não	Especifica a estratégia de roteamento de Tópico de destino para mensagens. Se ambos os parâmetros Topic e DynamicTopic forem especificados, o parâmetro DynamicTopic terá precedência. Dois modos de configuração são suportados: 1. Modo de constante estática: Especifique uma string de nome de Tópico fixa (por exemplo, "order_created"). Todas as mensagens são enviadas para este Tópico. 2. Modo de extração dinâmica: Especifique uma expressão JSONPath padrão (por exemplo, "$.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.
Value	string	Não	O valor.
Form	string	Não	O tipo de transformação. Valores válidos: CONSTANT: valor constante. JSONPATH: extrair do upstream com base no caminho.
Template	string	Não	O modelo.
Headers	object	Não	Os metadados adicionais da mensagem Kafka.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação. Valores válidos: ORIGINAL: evento completo JSONPATH: evento parcial CONSTANT: constante TEMPLATE: modelo	CONSTANT
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
Acks	object	Não	O modo de confirmação de gravação do Kafka. Valores válidos: acks=0: Nenhuma resposta é necessária do servidor. O desempenho é alto, mas o risco de perda de dados é alto. acks=1: Uma resposta é retornada após o nó primário gravar com sucesso. O desempenho é moderado e o risco de perda de dados é moderado. A perda de dados pode ocorrer se o nó primário cair. acks=all: Uma resposta é retornada após o nó primário gravar com sucesso e os nós secundários sincronizarem com sucesso. O desempenho é baixo, mas os dados são mais seguros. A perda de dados ocorre apenas se os nós primário e secundário caírem.
Value	string	Não	O modo de confirmação para gravação no Kafka: acks=0: Nenhuma resposta é necessária do servidor. O desempenho é alto, mas o risco de perda de dados é alto. acks=1: Uma resposta é retornada após o nó primário gravar com sucesso. O desempenho é moderado e o risco de perda de dados é moderado. A perda de dados pode ocorrer se o nó primário cair. acks=all: Uma resposta é retornada apenas após o nó primário gravar com sucesso e os nós secundários completarem a sincronização. O desempenho é baixo, mas os dados são mais seguros. A perda de dados ocorre apenas se os nós primário e secundário caírem.	1
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Key	object	Não	O identificador da mensagem.
Value	string	Não	O identificador da mensagem.	key
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Value	object	Não	O conteúdo do corpo da mensagem.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
SinkApacheKafkaParameters	object	Não	A descrição.
Bootstraps	string	Não
Topic	string	Não
DynamicTopic	object	Não	Especifica a estratégia de roteamento de Tópico de destino para mensagens. Se ambos os parâmetros Topic e DynamicTopic forem especificados, o parâmetro DynamicTopic terá precedência. Dois modos de configuração são suportados: 1. Modo de constante estática: Especifique uma string de nome de Tópico fixa (por exemplo, "order_created"). Todas as mensagens são enviadas para este Tópico. 2. Modo de extração dinâmica: Especifique uma expressão JSONPath padrão (por exemplo, "$.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.
Value	string	Não	O valor.
Form	string	Não	O tipo de transformação. Valores válidos: CONSTANT: valor constante. JSONPATH: extrair do upstream com base no caminho.
Template	string	Não	O modelo.
Acks	string	Não
Key	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
Value	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
CompressionType	string	Não
SecurityProtocol	string	Não
SaslMechanism	string	Não
SaslUser	string	Não
VpcId	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
VSwitchIds	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
SecurityGroupId	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
NetworkType	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
Headers	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
SaslPassword	string	Não
SslKeystoreCertificateChain	string	Não	[Obrigatório para autenticação mútua] A cadeia de certificados do cliente Kafka. Este parâmetro é obrigatório quando o servidor Kafka ativa a autenticação SSL mútua (ssl.client.auth=required). Formato: formato PEM codificado em Base64 contendo o certificado do cliente e a cadeia completa de certificados (certificado do cliente primeiro, certificado da CA intermediária em seguida, certificado da CA raiz opcional). Nota: garanta que o conteúdo de cada arquivo PEM comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----', então codifique o conteúdo concatenado em Base64.
SslKeyPassword	string	Não	[Obrigatório para chave privada criptografada] A senha da chave privada do cliente Kafka. Este parâmetro é obrigatório quando a chave privada do cliente é protegida por senha (o arquivo PEM contém marcadores 'Proc-Type: 4,ENCRYPTED' ou 'ENCRYPTED'). Deixe em branco se a chave privada não estiver criptografada. Nota: esta senha é usada apenas para descriptografar a chave privada e não está relacionada à autenticação do Kafka.
SslTruststoreCertificates	string	Não	[Obrigatório para SSL] O certificado de confiança do servidor Kafka. Usado para autenticar o certificado SSL do Broker Kafka para prevenir ataques man-in-the-middle. Formato: Codificação Base64 do formato PEM, tipicamente contendo o certificado da CA ou o certificado do servidor do servidor Kafka. Exemplo: Codifique em Base64 o conteúdo do arquivo PEM do certificado da CA (garanta que comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----'). Se o Kafka usar um certificado autoassinado, forneça o certificado da CA que emitiu o certificado.
SslKeystoreKey	object	Não	[Obrigatório para autenticação mútua] O objeto de configuração da chave privada SSL. Este parâmetro é obrigatório quando o servidor Kafka ativa a autenticação SSL mútua. Apenas o modo KMS é suportado: especifique o recurso do Key Management Service que armazena a chave privada através de KmsArn. O sistema recupera o conteúdo da chave privada do KMS apenas na memória para maior segurança. Exemplo de configuração: {"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}
KmsArn	string	Não	[Obrigatório] O ARN do recurso KMS que armazena a chave privada SSL. Usado para localizar a instância do Key Management Service que armazena a chave privada do cliente. Exemplo de formato: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. Obtenha este valor nas informações de ARN da chave correspondente no console KMS.
KmsSecretValueKey	string	Não	[Modo KMS KV] O nome da chave na credencial KMS. Quando a credencial KMS é armazenada como uma estrutura chave-valor (KV), especifique este parâmetro para indicar a chave correspondente à chave privada SSL. Exemplo: se a credencial KMS for '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', insira 'ssl_keystore_key'. Deixe em branco se a credencial KMS estiver no modo de texto simples (armazena diretamente o conteúdo PEM da chave privada).
SinkRocketMQParameters	object	Não	Parâmetros do Sink RocketMQ.
InstanceId	object	Não	O tipo de serviço de destino é ApsaraMQ for RocketMQ.
Value	string	Não	O ID da instância MSMQ for RocketMQ.	MQ_INST_164901546557**_BAAN**
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Topic	object	Não	O tópico da instância do ApsaraMQ for RocketMQ.
Value	string	Não	O tópico da instância MSMQ for RocketMQ.	Mytopic
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Body	object	Não	O conteúdo da mensagem.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
Properties	object	Não	As propriedades de filtro.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
Keys	object	Não	As propriedades de filtro.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
Tags	object	Não	As propriedades de filtro.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
InstanceType	object	Não	O tipo de instância.
Value	string	Não	O tipo de instância. Valores válidos: Cloud_4: Instância Alibaba Cloud RocketMQ 4.0 (padrão) Cloud_5: Instância Alibaba Cloud RocketMQ 5.0 SelfBuilt: Cluster Apache RocketMQ autogerenciado	Cloud_4
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
InstanceEndpoint	object	Não	O endpoint da instância.
Value	string	Não	O endpoint da instância.	vbr-8vbsvkkbpf3vb0zef****
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
InstanceUsername	object	Não	O nome de usuário da instância.
Value	string	Não	O nome de usuário da instância.	admin
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
InstancePassword	object	Não	A senha da instância.
Value	string	Não	A senha da instância.	admin****
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
VpcId	object	Não	O ID da VPC.
Value	string	Não	O ID da VPC.	vbr-8vb835n3zf9shwlvb****
Form	string	Não	O formato de transformação de evento. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
VSwitchIds	object	Não	O ID do vSwitch.
Value	string	Não	O ID do vSwitch.	vbr-8vb835n3zf9shwl****mp
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
SecurityGroupId	object	Não	O ID do grupo de segurança.
Value	string	Não	O ID do grupo de segurança.	b4bf375515f6440f942e3a20c33d****
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Network	object	Não	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork
Value	string	Não	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork	PublicNetwork
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
DeliveryOrderType	object	Não	O tipo de ordem de entrega da mensagem. Este parâmetro é opcional. Valor padrão: entrega concorrente.
Value	string	Não	O tipo de ordem de entrega. Valores válidos: Orderly: Entrega ordenada. Concurrently: Entrega concorrente.	Concurrently
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
ShardingKey	object	Não	A chave de sharding da mensagem. Nota Quando DeliveryOrderType está definido como Orderly, este parâmetro especifica a regra de transformação de conteúdo de evento para a propriedade ShardingKey ao gravar mensagens downstream. Quando a Origem é RocketMQ, ShardingKey pode estar vazio. Neste caso, o BrokerName e QueueId upstream são concatenados para gerar o ShardingKey da mensagem.
Value	string	Não	O valor da chave de sharding.	order_id
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
SinkDorisParameters	object	Não	O tipo de origem do evento.
QueryEndpoint	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
FeHttpEndpoint	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
BeHttpEndpoint	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
UserName	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
Password	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
Database	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
Body	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
Table	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
NetworkType	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
VpcId	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
VSwitchIds	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
SecurityGroupId	object	Não
Value	string	Não
Form	string	Não
Template	string	Não
SinkRocketMQCheckpointParameters	object	Não	Parâmetros do Sink RocketMQ Checkpoint.
InstanceType	string	Não	O tipo de instância. Valores válidos: Cloud_4: Instância do Alibaba Cloud RocketMQ 4.0 Cloud_5: Instância do Alibaba Cloud RocketMQ 5.0	Cloud_4
InstanceId	string	Não	O ID da instância.	MQ_INST_164901546557**_BAAN**
Topic	object	Não	O tópico da instância do ApsaraMQ for RocketMQ.
Value	string	Não	O nome do tópico da instância MSMQ for RocketMQ.	Mytopic
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
ConsumeTimestamp	object	Não	O timestamp de consumo da mensagem.
Value	string	Não	The timestamp.	1570761026400
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
Group	object	Não	O Group ID do grupo de consumidores.
Value	string	Não	Group ID	GID_EVENTBRIDGE_1736234******
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
SinkApacheRocketMQCheckpointParameters	object	Não	Parâmetros do Sink Apache RocketMQ Checkpoint.
Topic	object	Não	O tópico da instância RocketMQ.
Value	string	Não	The topic name of the RocketMQ instance.	Mytopic
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
ConsumeTimestamp	object	Não	O timestamp de consumo da mensagem.
Value	string	Não	The timestamp.	1570761026400
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
Group	object	Não	O Group ID do grupo de consumidores.
Value	string	Não	Group ID	GID_EVENTBRIDGE_1736234******
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
InstanceEndpoint	string	Não	O endpoint da instância.	192.168.1.1:9876
InstanceUsername	string	Não	O nome de usuário necessário para autenticação.	admin.
InstancePassword	string	Não	A senha do nome de usuário.	****
NetworkType	string	Não	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork	PrivateNetwork.
VpcId	string	Não	O ID da VPC.	vpc-2zeccak5pb0j3ay******
VSwitchId	string	Não	O ID do vSwitch.	vsw-uf62oqt1twuevrt******
SecurityGroupId	string	Não	O ID do grupo de segurança.	sg-2ze5bmpw6adn0q******
SinkSLSParameters	object	Não	Parâmetros do Sink SLS.
Project	object	Não	O projeto de logs do Simple Log Service (S.
Value	string	Não	The project of Simple Log Service.	test-project
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
LogStore	object	Não	The Logstore of Simple Log Service (SLS).
Value	string	Não	The Logstore of Simple Log Service.	test-logstore
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Topic	object	Não	The topic where the log resides, corresponding to the SLS reserved field "topic".
Value	string	Não	The topic where the log resides, corresponding to the SLS reserved field "topic".	testTopic
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Body	object	Não	The content sent to SLS.
Value	string	Não	O valor antes da transformação.	{ "key": "value" }
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
RoleName	object	Não	The role name used to authorize the event bus EventBridge to read SLS log content. When creating the role in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" and set "Trusted Service" to "EventBridge".
Value	string	Não	The role that provides authorization for the event bus EventBridge to read SLS log content. When creating the role in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" and set "Trusted Service" to "event bus".	testRole
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
ContentType	object	Não	The SLS data format. You can select the default format or configure specified key-value pairs. Valid values: JSON KeyValue
Value	string	Não	The SLS data format.	JSON
Form	string	Não	O formato de transformação.	CONSTANT
Template	string	Não	O estilo do modelo.
ContentSchema	object	Não	The custom log key-value pairs. 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	Não	The custom key-value pairs.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
Form	string	Não	O formato de transformação.	CONSTANT
Template	string	Não	O estilo do modelo.
SinkFnfParameters	object	Não	The Sink Fnf parameters.
FlowName	object	Não	The flow name.
Value	string	Não	The flow name.	test-streaming-fnf
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
ExecutionName	object	Não	The execution name.
Value	string	Não	The execution name.	123
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
Input	object	Não	The execution input information.
Value	string	Não	The execution input information.	123
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
RoleName	object	Não	The role configuration.
Value	string	Não	The role configuration.	Al**FNF-x**
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	O estilo do modelo.
SinkPrometheusParameters	object	Não	The Sink Prometheus parameters.
URL	object	Não	The Prometheus Remote Write URL.
Value	string	Não	The Prometheus Remote Write URL.	https://cn-hangzhou.arms.aliyuncs.com/prometheus/167275**/c5b7faeb2e8994641***d5c559f/cn-hangzhou/api/v3/write
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
HeaderParameters	object	Não	The data structure of the request header parameters.
Value	string	Não	If Form is CONSTANT: a constant value. If Form is JSONPATH: content extracted using JSONPath. If Form is TEMPLATE: a template variable. Note: The Value field cannot exceed 10,240 characters.	name
Form	string	Não	The transformation format. Valid values: JSONPATH: JSONPATH. CONSTANT: CONSTANT. TEMPLATE: TEMPLATE.	TEMPLATE
Template	string	Não	The HTTP request header template. Specify this parameter when Form is set to TEMPLATE. The transformed event content must be in JSON format.	{ "user_name":"${name}" }
AuthorizationType	object	Não	The authorization type.
Value	string	Não	O tipo de autenticação.	BASIC_AUTH
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Username	object	Não	The username.
Value	string	Não	The username.	***admin
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Password	object	Não	The password.
Value	string	Não	The password.	abc
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Data	object	Não	The metric content.
Value	string	Não	The metric content.	$.data
Form	string	Não	The transformation format. Default value: JSONPATH.	JSONPATH
Template	string	Não	Nenhum.
NetworkType	object	Não	O tipo de rede.
Value	string	Não	O tipo de rede. Valores válidos: PublicNetwork PrivateNetwork	PrivateNetwork
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
VpcId	object	Não	O ID da VPC.
Value	string	Não	O ID da VPC.	vpc-adw1awdw*****
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
VSwitchId	object	Não	O ID do vSwitch.
Value	string	Não	O ID do vSwitch.	vsw-dwaafds****
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
SecurityGroupId	object	Não	O ID do grupo de segurança.
Value	string	Não	O ID do grupo de segurança.	sg-mw43*****
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
SinkDataHubParameters	object	Não	The Sink DataHub parameters.
Project	object	Não	The DataHub project name.
Value	string	Não	The DataHub project name.	demo-project
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
Topic	object	Não	The DataHub topic name.
Value	string	Não	The DataHub topic name.	demo-topic
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
TopicType	object	Não	The topic type. Valid values: TUPLE BLOB
Value	string	Não	The topic type. Valid values: TUPLE BLOB	TUPLE
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
TopicSchema	object	Não	The TUPLE type topic content schema.
Value	string	Não	The topic content schema for the TUPLE type.	{"k1":"value1","k2":"value2"}
Form	string	Não	O formato de transformação.	TEMPLATE
Template	string	Não	O estilo do modelo.	{"k1":"${k1}","k2":"${k2}"}
Body	object	Não	The BLOB type Record content template.
Value	string	Não	The record content template for the BLOB type.
Form	string	Não	O formato de transformação.	ORIGINAL
Template	string	Não	Nenhum.
RoleName	object	Não	O nome da função da tarefa.
Value	string	Não	O nome da função da tarefa.	test-role
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Template	string	Não	Nenhum.
ContentType	object	Não	The data format. You can select the default format or configure specified key-value pairs. Valid values: JSON KeyValue
Value	string	Não	O valor antes da transformação.	JSON
Form	string	Não	O formato de transformação.	CONSTANT
Template	string	Não	O estilo do modelo.
ContentSchema	object	Não	The custom log key-value pairs. 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	Não	O valor antes da transformação.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
Form	string	Não	O estilo do modelo.	CONSTANT
Template	string	Não	O estilo do modelo.
SinkCustomizedKafkaParameters	object	Não	Os parâmetros do Sink Kafka.
InstanceId	string	Não	O ID da instância do ApsaraMQ for Kafka.	90be1f96-4229-4535-bb76-34b4f6fb2b71
SinkCustomizedKafkaConnectorParameters	object	Não	The Sink Kafka connector parameters.
ConnectorPackageUrl	string	Não	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=rb8q3OpV2i3gZJ"
ConnectorParameters	object	Não	Parses the properties file in the current ZIP package.
Name	string	Não	O nome do conector.	mongo-sink
Config	object	Não	A configuração do conector.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
WorkerParameters	object	Não	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	Não	The Sink DashVector parameters.
InstanceId	string	Não	O ID da instância.	vrs-cn-lbj3ru1***
Collection	string	Não	The collection name.	collection1
ApiKey	string	Não	The API key created in the DashVector console.	Q34nExQH7sQ****
Operation	string	Não	The DashVector database operation type. Valid values: Delete Upsert	Upsert
Network	string	Não	The network type. Valid values: PrivateNetwork PublicNetwork	PublicNetwork.
PrimaryKeyId	object	Não	The primary key ID when inserting or deleting records. If this field is not specified, a random primary key ID is used.
Form	string	Não	The transformation format. Valid values: JSONPATH TEMPLATE	JSONPATH
Value	string	Não	If Form is JSONPATH: content extracted using JSONPath. If Form is TEMPLATE: a template variable. Nota The Value field cannot exceed 10,240 characters.	$.data.requestId
Template	string	Não	The primary key ID template. Specify this parameter only when Form is set to TEMPLATE.	${ID}
Partition	object	Não	The partition. Default value: default.
Form	string	Não	The transformation format. Valid values: JSONPATH CONSTANT	CONSTANT
Value	string	Não	If Form is CONSTANT: a constant value. If Form is JSONPATH: content extracted using JSONPath. Nota The Value field cannot exceed 10,240 characters.	default
Template	string	Não	Nenhum.
Vector	object	Não	The vector of the record inserted into DashVector.
Form	string	Não	O formato de transformação.	JSONPATH
Value	string	Não	The content extracted using JSONPath. Nota The Value field cannot exceed 10,240 characters.	$.data.messageBody
Template	string	Não	Nenhum.
DashVectorSchemaParameters	array<object>	Não	The Schema field definition of the table entry when inserting into DashVector. The event content transformation result must be in JSON format.
	array<object>	Não
Name	object	Não
Form	string	Não
Value	string	Não
Template	string	Não
Type	object	Não
Form	string	Não
Value	string	Não
Template	string	Não
Value	object	Não
Form	string	Não
Value	string	Não
Template	string	Não
SinkOpenSourceRabbitMQParameters	object	Não	Sink Open Source RabbitMQ Parameters
Endpoint	string	Não	The endpoint.	192.168.1.1:9876
VirtualHostName	string	Não	The virtual host name of the RabbitMQ instance.	Vhost1
TargetType	string	Não	The target type for message delivery. Valid values: Exchange: Messages are routed through an exchange. Queue: Messages are delivered directly to the specified queue.	Exchange
Exchange	string	Não	The Exchange name in RabbitMQ. This parameter takes effect when TargetType is set to Exchange.	my-exchange
QueueName	string	Não	The queue name in RabbitMQ. This parameter takes effect only when TargetType is set to Queue.	my-queue
Username	string	Não	The username used to access the RabbitMQ instance.	admin.
Password	string	Não	The password used to access the RabbitMQ instance.	****
VpcId	string	Não	O ID da VPC.	vpc-uf6of9452b2pba82c ****
VSwitchIds	string	Não	O ID do vSwitch.	vsw-uf6of9452b2pba82c ****
SecurityGroupId	string	Não	O ID do grupo de segurança.	sg-uf6of9452b2pba82c ****
NetworkType	string	Não	The network type. Valid values: PrivateNetwork PublicNetwork	PublicNetwork.
AuthType	string	Não	The authentication type. Valid values: ACL No configuration required	ACL.
RoutingKey	object	Não	The message routing key.
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Value	string	Não	The routing key value.	{"Form": "CONSTANT", "Value": "my-routing-key"}
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
Body	object	Não	O conteúdo do corpo da mensagem.
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Value	string	Não	The raw data value.	{"key": "value"}
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
MessageId	object	Não	The unique identifier of the message.
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Value	string	Não	The message ID value.	12345
Template	string	Não	O estilo do modelo.
Properties	object	Não	The additional properties of the message.
Form	string	Não	O formato de transformação. Valor padrão: CONSTANT.	CONSTANT
Value	string	Não	The property content.	{"env": "prod"}
Template	string	Não	O estilo do modelo.	The value of ${key} is ${value}!
SinkBaiLianParameters	SinkBaiLianParameters	Não	Sink BaiLian Parameters
SinkDataWorksTriggerParameters	SinkDataWorksTriggerParameters	Não
SinkHttpsParameters	SinkHttpsParameters	Não	The HTTPS target parameters.
SinkApiDestinationParameters	SinkApiDestinationParameters	Não	The ApiDestination target parameters.
SinkOSSParameters	SinkOSSParameters	Não
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters	Não
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters	Não
SinkMQTTParameters	SinkMQTTParameters	Não
SinkAgentRunParameters	SinkAgentRunParameters	Não
RunOptions	object	Não	The runtime parameters.
MaximumTasks	integer	Não	The concurrency.	2
ErrorsTolerance	string	Não	The error tolerance policy: NONE (no error tolerance) or ALL (tolerate all errors).	ALL
RetryStrategy	object	Não	The retry strategy when event push fails.
PushRetryStrategy	string	Não	The retry strategy: BACKOFF_RETRY (backoff retry) or EXPONENTIAL_DECAY_RETRY (exponential decay retry).	BACKOFF_RETRY
MaximumEventAgeInSeconds	integer	Não	The maximum retry time.	512
MaximumRetryAttempts	integer	Não	The maximum number of retry attempts.	2
DeadLetterQueue	object	Não	Specifies whether to enable the dead-letter queue. The dead-letter queue is disabled by default. Messages that exceed the retry policy are discarded.
Arn	string	Não	The ARN of the dead-letter queue.	acs:ram::131733464781****:role/rdstoecsassumekms
Network	string	Não	The network type of the dead-letter queue. Valid values: PrivateNetwork PublicNetwork	PrivateNetwork.
VpcId	string	Não	The VPC ID of the dead-letter queue.	vpc-2zehizpoendb3****
VSwitchIds	string	Não	The vSwitch ID of the dead-letter queue.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	Não	The security group ID of the dead-letter queue instance.	sg-2vcgdxz7o1n9zapp****
BatchWindow	object	Não	The batching window.
CountBasedWindow	integer	Não	The maximum number of events that can be contained in the window. When this threshold is reached, the data in the window is pushed downstream. If multiple windows exist, a push is triggered when any window meets the threshold.	100
TimeBasedWindow	integer	Não	The maximum time range (in seconds) for events in the window. When this threshold is reached, the data in the window is pushed downstream. If multiple windows exist, a push is triggered when any window meets the threshold.	10
BusinessOption	object	Não
BusinessMode	string	Não
MinCapacityUnitCount	integer	Não
MaxCapacityUnitCount	integer	Não
Throttling	integer	Não
Transforms	array<object>	Não	The Transform-related configurations.
	object	Não	The ARN of the cloud product, such as the ARN of a function in Function Compute.
Arn	string	Não	The ARN of the cloud product, such as the ARN of a function in Function Compute.	acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
DashScopeTransformParameters	DashScopeTransformParameters	Não
BaiLianAgentTransformParameters	BaiLianAgentTransformParameters	Não

Elementos de resposta

Elemento	Tipo	Descrição	Exemplo
	object	The response parameters.
Message	string	The error message.	The name [xxxx] of event streaming in request is already exist!
RequestId	string	The request ID generated by Alibaba Cloud for this request.	0FDD73AA-7A2D-5BD4-B4C0-88AFEBF5F0F5
Code	string	The response code. Success indicates a successful call. Other values indicate error codes. For more information, see Error codes.	Success
Success	boolean	Returns true if the operation is successful.	true.

Exemplos

Resposta de sucesso

JSON formato

{
  "Message": "The name [xxxx] of event streaming in request is already exist!",
  "RequestId": "0FDD73AA-7A2D-5BD4-B4C0-88AFEBF5F0F5",
  "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.