Todos os produtos
Search
Central de documentação

EventBridge:UpdateEventStreaming

Última atualização: Oct 29, 2026

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 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 exatamente um tipo de origem e configurar seus parâmetros.

SourceApacheKafkaParameters

object

Não

As configurações de parâmetros para o Kafka de código aberto.

Bootstraps

string

Não

O endpoint.

"Bootstraps"

ConsumerGroup

string

Não

O nome do grupo de consumidores.

DEFAULT_GROUP

NetworkType

string

Não

Especifica o tipo de rede do cluster Kafka.

PrivateNetwork

OffsetReset

string

Não

O deslocamento de consumo. Valores válidos:\n- latest: O sistema lê dados a partir do deslocamento mais recente.\n- earliest: O sistema lê dados a partir do deslocamento mais antigo. Este valor é suportado apenas quando um grupo de consumidores não utilizado é inicializado pela primeira vez.

latest

SaslMechanism

string

Não

O mecanismo de autenticação SASL do Kafka.

"SaslMechanism"

SaslPassword

string

Não

A senha de autenticação SASL do Kafka.

yourPassword

SaslUser

string

Não

O nome de usuário de autenticação SASL do Kafka.

"SaslUser"

SecurityGroupId

string

Não

O ID do grupo de segurança para a origem Kafka.

sg-bp1iv19sp1msc7zot4****

SecurityProtocol

string

Não

O tipo de protocolo de segurança do Kafka. Valores válidos:\n- SASL_SSL\n- PLAINTEXT\n- SASL_PLAINTEXT.

SASL_SSL

SslKeyPassword

string

Não

[Obrigatório para chaves privadas criptografadas] A senha da chave privada do cliente Kafka. Se a chave privada do cliente for protegida por criptografia de senha (o arquivo PEM contém a tag 'Proc-Type: 4,ENCRYPTED' ou 'ENCRYPTED'), você deve fornecer a senha de descriptografia. Se a chave privada não estiver criptografada, deixe este parâmetro vazio. Nota: Esta senha é usada apenas para descriptografar a chave privada e não está relacionada à autenticação do Kafka.

yourPassword

SslKeystoreCertificateChain

string

Não

[Obrigatório para autenticação mútua] A cadeia de certificados do cliente Kafka. Se a autenticação SSL mútua (ssl.client.auth=required) estiver ativada no servidor Kafka, você deve fornecer este parâmetro. Requisitos de formato: formato PEM codificado em Base64, incluindo o certificado do cliente e a cadeia de certificados completa (o certificado do cliente primeiro, seguido pelos certificados de CA intermediários, e o certificado de CA raiz é opcional). Nota: Certifique-se de que cada arquivo PEM comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----' antes de concatená-los e codificá-los em Base64.

"SslKeystoreCertificateChain"

SslKeystoreKey

object

Não

[Obrigatório para autenticação bidirecional] O objeto de configuração da chave privada SSL. Se a autenticação SSL bidirecional estiver ativada no servidor Kafka, você deve fornecer a chave privada do cliente. Apenas o padrão KMS é suportado para a chave: especifique o recurso EPS do Key Management Service (KMS) que armazena a chave privada usando KmsArn. O sistema recupera o conteúdo da chave privada do KMS apenas na memória, o que proporciona 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. Este parâmetro é usado para localizar a instância do KMS que armazena a chave privada do cliente. Exemplo de formato: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. Para obter o ARN, visualize as informações de ARN da chave correspondente no console do KMS.

"KmsArn"

KmsSecretValueKey

string

Não

[Modo KMS KV] O nome da chave no segredo do KMS. Se o segredo armazenado no KMS estiver em uma estrutura de par chave-valor (KV), especifique este parâmetro para indicar a chave correspondente à chave privada SSL. Exemplo: Se o segredo do KMS for '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', insira 'ssl_keystore_key'. Se o segredo do KMS estiver no modo de texto simples (armazenando diretamente o conteúdo PEM da chave privada), deixe este parâmetro vazio.

"KmsSecretValueKey"

SslTruststoreCertificates

string

Não

[Obrigatório para cenários SSL] O certificado de confiança do servidor Kafka. Este parâmetro é usado para autenticar a validade do certificado SSL do broker Kafka e evitar ataques man-in-the-middle. Requisitos de formato: formato PEM com codificação Base64, que normalmente inclui o certificado de CA do servidor Kafka ou o próprio certificado do servidor. Exemplo: Realize a codificação Base64 no conteúdo do arquivo PEM do certificado de CA (certifique-se de que comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----'). Se o Kafka usar um certificado autoassinado, você deve fornecer o certificado de CA que emitiu o certificado.

"SslTruststoreCertificates"

Topic

string

Não

O nome do tópico.

LTC_CACHE_PRD

VSwitchIds

string

Não

A lista de IDs de vSwitch para a origem Kafka.

vsw-bp179l3llg3jjxwrq72****

ValueDataType

string

Não

O tipo de dados. Valores válidos:\n- Text\n- Binary\n- Json.

JSON

VpcId

string

Não

O ID da VPC da origem Kafka.

vpc-8vblalsi0vbhizr77****

SourceApacheRocketMQCheckpointParameters

object

Não

A origem de ponto de verificação do RocketMQ.

InstanceEndpoint

string

Não

O endpoint da instância do Apache RocketMQ.

192.168.1.1:9876

InstancePassword

string

Não

A senha da instância do Apache RocketMQ.

yourPassword

InstanceUsername

string

Não

O nome de usuário da instância do Apache RocketMQ.

admin

NetworkType

string

Não

O tipo de rede. Valores válidos:\n- PublicNetwork\n- PrivateNetwork.

PrivateNetwork

RegionId

string

Não

O ID da região.

cn-hangzhou

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-mw43*****

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

VSwitchId

string

Não

O ID do vSwitch.

vsw-dwaafds****

VpcId

string

Não

O ID da VPC.

vpc-adw1awdw*****

SourceCustomizedKafkaConnectorParameters

object

Não

A origem de eventos do Apache Kafka do conector personalizado.

ConnectorPackageUrl

string

Não

A URL de download do pacote ZIP do recurso 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.

Config

object

Não

A configuração do conector.

{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }

Name

string

Não

O nome do conector.

test-name

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" }

SourceCustomizedKafkaParameters

object

Não

A origem de eventos Kafka personalizada.

InstanceId

string

Não

O ID da instância do MSMQ para Apache Kafka.

r-8vb64581862c****

SourceDTSParameters

object

Não

A origem DTS.

BrokerUrl

string

Não

O endereço de rede e o número da porta do canal de assinatura de dados.

"BrokerUrl"

InitCheckPoint

integer

Não

O deslocamento de consumo, que é o carimbo de data e hora em que o cliente SDK consome o primeiro dado. O valor é um carimbo de data e hora UNIX.

1620962769

Password

string

Não

A senha da conta do grupo de consumidores.

admin

Sid

string

Não

O ID do grupo de consumidores.

hkprdb

TaskId

string

Não

O ID da tarefa.

f86e5814-b223-482c-b768-3b873297****

Topic

string

Não

O tópico de assinatura do canal de assinatura de dados.

LTC_CACHE_PRD

Username

string

Não

A conta do grupo de consumidores.

admin

SourceEventBusParameters

object

Não

A origem do barramento de eventos.

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

SourceFeiShuDocsParameters SourceFeiShuDocsParameters

Não

Os parâmetros da origem de documentos do Lark.

SourceJDBCParameters SourceJDBCParameters

Não

Os parâmetros da origem de dados JDBC.

SourceKafkaParameters

object

Não

Os parâmetros do Kafka de origem.

ConsumerGroup

string

Não

O ID do grupo do consumidor que assina o tópico.

DEFAULT_GROUP

InstanceId

string

Não

O ID da instância.

i-8vbh4a5b9yfhgkkzm****

Network

string

Não

A configuração de rede. Valor padrão: Default. Para redes VPC, defina este parâmetro como PublicNetwork.

Default

OffsetReset

string

Não

O offset.

latest

RegionId

string

Não

O ID da região.

cn-zhangjiakou

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-uf6jcm3y5hcs7hkl****

Topic

string

Não

O nome do tópico.

topic_empower_1641539400786

VSwitchIds

string

Não

O ID do vSwitch.

vsw-wz9t1l1e8eu2om****

ValueDataType

string

Não

O parâmetro de codificação e decodificação. Valores válidos:

  • Json: usa a lógica existente. Os bytes são decodificados em strings usando UTF-8 e analisados como JSON.

  • Text: os bytes são decodificados em strings usando UTF-8 e colocados diretamente na carga útil.

  • Binary: os bytes são codificados em strings usando a codificação Base64 e colocados na carga útil.

Text

VpcId

string

Não

O ID da VPC.

vpc-2ze6p0o345nykmekxt****

SourceMNSParameters

object

Não

Os parâmetros do Simple Message Queue (anteriormente MNS) de origem.

IsBase64Decode

boolean

Não

Especifica se a codificação Base64 deve ser ativada. Valor padrão: true.

true

QueueName

string

Não

O nome da fila.

queue_api_1642474203601

RegionId

string

Não

O ID da região.

cn-hangzhou

SourceMQTTParameters

object

Não

Os parâmetros do MQTT de origem.

BodyDataType

string

Não

O formato de codificação da mensagem. Valores válidos:

  • JSON

  • Text

  • Binary

JSON

InstanceId

string

Não

O ID da instância.

i-bp1dsudbecqwt61j****

NetworkType

string

Não

O tipo de rede.

PrivateNetwork

RegionId

string

Não

O ID da região.

cn-shanghai

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

Topic

string

Não

O nome do tópico.

topic_empower_1642400400779

VSwitchIds

string

Não

Os IDs dos vSwitches.

vsw-bp179l3llg3jjxwrq72****

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

SourceMySQLParameters SourceMySQLParameters

Não

Os parâmetros do MySQL de origem.

SourceOSSParameters

object

Não

Os parâmetros do OSS de origem.

BucketName

string

Não

O nome do bucket do OSS.

bucket_abc

Delimiter

string

Não

O delimitador. No modo de carregamento em blocos, este delimitador é usado como identificador de bloco para texto. Valor padrão: \n (quebra de linha).

\n

FileExtensions

array

Não

A lista de permissões de extensões de arquivo.

["pdf","docx"]

string

Não

O tipo de extensão.

txt

LoadFormat

string

Não

O carregador de documentos.

TextLoader

LoadMode

string

Não

O modo de carregamento de dados. Valores válidos:

  • single: carrega um único documento.

  • element: carrega dados em blocos. Valor padrão: single.

single

Prefix

string

Não

O prefixo do caminho do arquivo.

fun/document/

RoleName

string

Não

O nome da função RAM que autoriza o EventBridge a ler arquivos do OSS. A função deve ter pelo menos permissões de somente leitura no OSS.

eventbridge_oss_role

SourceOpenSourceRabbitMQParameters

object

Não

Os parâmetros do RabbitMQ de código aberto de origem.

AuthType

string

Não

O tipo de autenticação.

ACL

BodyDataType

string

Não

O tipo de dados do corpo da mensagem.

Json

Endpoint

string

Não

O endpoint da instância.

192.168.1.1:9876

NetworkType

string

Não

O tipo de rede. Valores válidos:\n- PublicNetwork\n- PrivateNetwork.

PrivateNetwork

Password

string

Não

A senha usada para conectar à instância RabbitMQ de código aberto.

yourPassword

QueueName

string

Não

O nome da fila da instância RabbitMQ de código aberto.

demo

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-m5edtu24f12345****

Username

string

Não

O nome de usuário usado para conectar à instância RabbitMQ de código aberto.

admin

VSwitchIds

string

Não

O ID do vSwitch.

vsw-m5ev8asdc6h12345****

VirtualHostName

string

Não

O nome do vhost da instância RabbitMQ de código aberto.

Vhost1

VpcId

string

Não

O ID da VPC.

vpc-m5e3sv4b12345****

SourcePostgreSQLParameters SourcePostgreSQLParameters

Não

Os parâmetros do PostgreSQL de origem.

SourcePrometheusParameters

object

Não

Os parâmetros da origem de eventos do Prometheus.

ClusterId

string

Não

O ID do cluster.

c83555068b6******ad213f565f209

DataType

string

Não

O tipo de dados.

Json

ExternalLabels

string

Não

Os rótulos externos anexados ao fluxo de eventos.

{"env":"test"}

Labels

string

Não

Os rótulos.

__name__=.*

RegionId

string

Não

O ID da região da instância.

cn-hangzhou

RoleName

string

Não

O nome da função da tarefa.

test-role

SourceRabbitMQMetaParameters SourceRabbitMQMetaParameters

Não

Os parâmetros de metadados do ApsaraMQ for RabbitMQ de origem.

SourceRabbitMQMsgSyncParameters SourceRabbitMQMsgSyncParameters

Não

Os parâmetros de sincronização de mensagens do ApsaraMQ for RabbitMQ de origem.

SourceRabbitMQParameters

object

Não

Os parâmetros do RabbitMQ de origem.

InstanceId

string

Não

O ID da instância do ApsaraMQ for RabbitMQ.

i-f8z9lqkldlb4oxsxwwub

NetworkType

string

Não

O tipo de rede usado para conectar à instância RabbitMQ de origem. Valores válidos:

  • PublicNetwork: a Internet.

  • PrivateNetwork: uma VPC. Se você definir este parâmetro como PrivateNetwork, também deverá configurar VpcId, VSwitchIds e SecurityGroupId. Ao atualizar um fluxo de eventos e desejar manter a configuração original da VPC, você deve passar esses parâmetros de rede ao mesmo tempo.

PrivateNetwork

QueueName

string

Não

O nome da fila da instância do ApsaraMQ for RabbitMQ.

demo

RegionId

string

Não

O ID da região.

cn-hangzhou

SecurityGroupId

string

Não

O ID do grupo de segurança usado para conectar à instância RabbitMQ de origem. Este parâmetro é obrigatório quando NetworkType está definido como PrivateNetwork.

sg-bp1xxxxxxxxxxxx

VSwitchIds

string

Não

Os IDs dos vSwitches usados para conectar à instância RabbitMQ de origem. Separe vários IDs de vSwitch com vírgulas (,). Este parâmetro é obrigatório quando NetworkType está definido como PrivateNetwork.

vsw-bp1xxxxxxxxxxxx,vsw-bp1yyyyyyyyyyyy

VirtualHostName

string

Não

O nome do vhost da instância do ApsaraMQ for RabbitMQ.

eb-connect

VpcId

string

Não

O ID da VPC da instância RabbitMQ de origem. Este parâmetro é obrigatório quando NetworkType está definido como PrivateNetwork.

vpc-bp1xxxxxxxxxxxx

SourceRocketMQCheckpointParameters

object

Não

A origem de ponto de verificação do RocketMQ.

InstanceId

string

Não

O ID da instância do ApsaraMQ for RocketMQ.

rmq-cn-jte3w******

InstanceType

string

Não

O tipo da instância do ApsaraMQ for RocketMQ.

Cloud_5

RegionId

string

Não

O ID da região.

cn-hangzhou

Topics

array

Não

Os tópicos da instância do ApsaraMQ for RocketMQ.

string

Não

Os tópicos da instância do ApsaraMQ for RocketMQ.

myTopic

SourceRocketMQParameters

object

Não

Os parâmetros de origem do RocketMQ.

AuthType

string

Não

O tipo de autenticação.

ACL

BodyDataType

string

Não

O formato de codificação da mensagem. Valores válidos:

  • Json

  • Text

  • Binary

Json

FilterSql

string

Não

A instrução de filtro SQL.

index > 10

FilterType

string

Não

O tipo de filtragem de mensagens.

Tag

GroupID

string

Não

O ID do grupo da fila de mensagens MSMQ RocketMQ.

GID_test

InstanceEndpoint

string

Não

O endpoint da instância.

reg****-vpc.cn-zhangjiakou.aliyuncs.com

InstanceId

string

Não

O ID da instância da fila de mensagens MSMQ RocketMQ.

i-f8z9a9mcgwri1c1id****

InstanceNetwork

string

Não

O tipo de rede da instância. Valores válidos:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

InstancePassword

string

Não

A senha da instância.

admin

InstanceSecurityGroupId

string

Não

O ID do grupo de segurança da instância.

sg-m5edtu24f12345****

InstanceType

string

Não

O tipo de instância. Valores válidos:

  • Cloud_4 (padrão): Instância do ApsaraMQ for RocketMQ 4.0.

  • Cloud_5: Instância do ApsaraMQ for RocketMQ 5.0.

  • SelfBuilt: Instância do Apache RocketMQ autogerenciada.

Cloud_5

InstanceUsername

string

Não

O nome de usuário da instância.

admin

InstanceVSwitchIds

string

Não

Os IDs dos vSwitches da instância.

vsw-m5ev8asdc6h12****

InstanceVpcId

string

Não

O ID da VPC da instância.

vpc-m5e3sv4b12345****

Network

string

Não

O tipo de rede. Valores válidos:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

Offset

string

Não

O offset de consumo de mensagens. Valores válidos:

  • CONSUMEFROMLASTOFFSET: Consome mensagens a partir do offset mais recente.

  • CONSUMEFROMFIRSTOFFSET: Consome mensagens a partir do offset mais antigo.

  • CONSUMEFROMTIMESTAMP: Consome mensagens a partir do offset em um ponto específico no tempo.

Valor padrão: CONSUMEFROMLAST_OFFSET.

CONSUMEFROMLASTOFFSET

RegionId

string

Não

O ID da região da fila de mensagens MSMQ RocketMQ.

cn-shanghai

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-m5edtu24f12345****

Tag

string

Não

A tag de filtro da mensagem.

test

Timestamp

integer

Não

O timestamp. Este parâmetro é válido apenas quando o parâmetro Offset é definido como CONSUMEFROMTIMESTAMP.

1670656652009

Topic

string

Não

O nome do tópico.

TOPIC-cainiao-pcs-order-process-inBoundConditionCheck

VSwitchIds

string

Não

O ID do vSwitch.

vsw-m5ev8asdc6h12345****

VpcId

string

Não

O ID da VPC da instância.

vpc-m5e3sv4b12345****

SourceSLSParameters

object

Não

Os parâmetros de origem do Simple Log Service (SLS).

RoleName

string

Não

O nome da função. Para a autorização do barramento de eventos EventBridge 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 o serviço confiável deve ser o barramento de eventos.

testRole

Metadata

string

Não

As configurações JSON comuns para provedores de eventos. Este parâmetro é mutuamente exclusivo com Source.

{"key":"value"}

Sink

object

Não

O destino do evento. Você deve selecionar um destino e pode configurar apenas um destino.

SinkAgentRunParameters SinkAgentRunParameters

Não

Os parâmetros de entrega para o tempo de execução do agente.

SinkApacheKafkaParameters

object

Não

A descrição.

Acks

string

Não

O modo de confirmação para gravar dados no Kafka. Valores válidos:

  • acks=0: Nenhuma resposta do servidor é necessária. Este modo oferece alto desempenho, mas apresenta alto risco de perda de dados.

  • 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 falhar.

  • acks=all: Uma resposta é retornada somente após o nó primário gravar os dados com sucesso e os nós secundários sincronizarem os dados. Este modo oferece menor desempenho, mas garante maior segurança dos dados. Os dados são perdidos apenas se os nós primário e secundário falharem.

all

Bootstraps

string

Não

Os endpoints iniciais do cluster Kafka.

"Bootstraps"

CompressionType

string

Não

O tipo de compactação.

"CompressionType"

DynamicTopic

object

Não

A política de roteamento de tópico de destino para mensagens. Se os parâmetros Topic e DynamicTopic forem especificados, o valor do parâmetro DynamicTopic terá precedência. Os seguintes modos de configuração são suportados:

  1. 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.

  2. 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

Não

O tipo de conversão. Valores válidos:

  • CONSTANT: Um valor fixo.

  • JSONPATH: Extraído da mensagem upstream com base no caminho especificado.

CONSTANT

Template

string

Não

O modelo.

The template string, if any

Value

string

Não

O valor.

"DynamicTopic"

Headers

object

Não

Os cabeçalhos da mensagem.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

Os cabeçalhos da mensagem.

"Headers"

Key

object

Não

A chave da mensagem.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

A chave da mensagem.

key

NetworkType

object

Não

O tipo de rede.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tipo de rede.

PrivateNetwork

SaslMechanism

string

Não

O mecanismo de autenticação SASL do Kafka.

"SaslMechanism"

SaslPassword

string

Não

A senha de autenticação SASL do Kafka.

yourPassword

SaslUser

string

Não

O nome de usuário de autenticação SASL do Kafka.

"SaslUser"

SecurityGroupId

object

Não

O ID do grupo de segurança.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID do grupo de segurança.

sg-mw43*****

SecurityProtocol

string

Não

O tipo de protocolo de segurança do Kafka. Valores válidos:\n- SASL_SSL\n- PLAINTEXT\n- SASL_PLAINTEXT.

SASL_SSL

SslKeyPassword

string

Não

[Obrigatório para chaves privadas criptografadas] A senha da chave privada do cliente Kafka. Se a chave privada do cliente for protegida por criptografia de senha (o arquivo PEM contém a tag 'Proc-Type: 4,ENCRYPTED' ou 'ENCRYPTED'), você deve fornecer a senha de descriptografia. Se a chave privada não estiver criptografada, deixe este parâmetro vazio. Nota: Esta senha é usada apenas para descriptografar a chave privada e não está relacionada à autenticação do Kafka.

yourPassword

SslKeystoreCertificateChain

string

Não

[Obrigatório para autenticação mútua] A cadeia de certificados do cliente Kafka. Se a autenticação SSL mútua (ssl.client.auth=required) estiver ativada no servidor Kafka, você deve fornecer este parâmetro. Requisitos de formato: formato PEM codificado em Base64, incluindo o certificado do cliente e a cadeia de certificados completa (o certificado do cliente primeiro, seguido pelos certificados de CA intermediários, e o certificado de CA raiz é opcional). Nota: Certifique-se de que cada arquivo PEM comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----' antes de concatená-los e codificá-los em Base64.

"SslKeystoreCertificateChain"

SslKeystoreKey

object

Não

[Obrigatório para autenticação bidirecional] O objeto de configuração de chave privada SSL. Quando a autenticação SSL bidirecional está ativada no servidor Kafka, você deve fornecer a chave privada do cliente. A chave suporta apenas o modo KMS: especifique o recurso do Key Management Service (KMS) que armazena a chave privada usando KmsArn. O sistema recupera o conteúdo da chave privada do KMS apenas na memória, o que proporciona 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. Este parâmetro é usado para localizar a instância do KMS que armazena a chave privada do cliente. Exemplo de formato: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. Para obter o ARN, visualize as informações de ARN da chave correspondente no console do KMS.

"KmsArn"

KmsSecretValueKey

string

Não

[Modo KMS KV] O nome da chave no segredo do KMS. Se o segredo armazenado no KMS estiver em uma estrutura de par chave-valor (KV), especifique este parâmetro para indicar a chave correspondente à chave privada SSL. Exemplo: Se o segredo do KMS for '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', insira 'ssl_keystore_key'. Se o segredo do KMS estiver no modo de texto simples (armazenando diretamente o conteúdo PEM da chave privada), deixe este parâmetro vazio.

"KmsSecretValueKey"

SslTruststoreCertificates

string

Não

[Obrigatório em cenários SSL] O certificado de confiança do servidor Kafka. É usado para autenticar a validade do certificado SSL do broker Kafka e evitar ataques man-in-the-middle. Requisitos de formato: formato PEM com codificação Base64, que geralmente contém o certificado de CA do servidor Kafka ou o próprio certificado do servidor. Exemplo: Realize a codificação Base64 no conteúdo do arquivo PEM do certificado de CA (certifique-se de que comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----'). Se o Kafka usar um certificado autoassinado, você deve fornecer o certificado de CA que emitiu o certificado.

"SslTruststoreCertificates"

Topic

string

Não

O nome do tópico.

LTC_CACHE_PRD

VSwitchIds

object

Não

A lista de IDs de vSwitch para a origem Kafka.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

A lista de IDs de vSwitch para a origem Kafka.

vbr-8vb835n3zf9shwl****mp

Value

object

Não

O corpo da mensagem.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O corpo da mensagem.

$.data.content

VpcId

object

Não

O ID da VPC.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID da VPC.

i-2ze7u5i17mbqtx1p****

SinkApacheRocketMQCheckpointParameters

object

Não

O tipo de origem do evento.

ConsumeTimestamp

object

Não

O carimbo de data/hora em que a mensagem é consumida.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O carimbo de data/hora.

1570761026400

Group

object

Não

O ID do grupo do grupo de consumidores.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O grupo de consumidores.

GID_EVENTBRIDGE_1736234******

InstanceEndpoint

string

Não

O endpoint da instância.

192.168.1.1:9876

InstancePassword

string

Não

A senha.

yourPassword

InstanceUsername

string

Não

O nome de usuário necessário para autenticação.

admin

NetworkType

string

Não

O tipo de rede. Valores válidos:

  • PublicNetwork

  • PrivateNetwork

PrivateNetwork

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-2ze5bmpw6adn0q******

Topic

object

Não

O tópico da instância do ApsaraMQ for RocketMQ.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome do tópico na instância do ApsaraMQ for RocketMQ.

Mytopic

VSwitchId

string

Não

O ID do vSwitch.

vsw-uf62oqt1twuevrt******

VpcId

string

Não

O ID da VPC.

vpc-2zeccak5pb0j3ay******

SinkApiDestinationParameters SinkApiDestinationParameters

Não

Os parâmetros de destino da API.

SinkBaiLianParameters SinkBaiLianParameters

Não

Os parâmetros de entrega do Model Studio.

SinkCustomizedKafkaConnectorParameters

object

Não

Os parâmetros do conector Kafka do sink.

ConnectorPackageUrl

string

Não

A URL de download do arquivo 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

O arquivo de propriedades no pacote ZIP atual.

Config

object

Não

A configuração do conector.

{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }

Name

string

Não

O nome do conector.

mongo-sink

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" }

SinkCustomizedKafkaParameters

object

Não

Os parâmetros do Kafka do sink.

InstanceId

string

Não

O ID da instância do MSMQ para Apache Kafka.

90be1f96-4229-4535-bb76-34b4f6fb2b71

SinkDashVectorParameters

object

Não

Os parâmetros do DashVector do sink.

ApiKey

string

Não

A chave de API criada no console do DashVector.

Q34nExQH7sQ****

Collection

string

Não

O nome da coleção.

collection1

DashVectorSchemaParameters

array<object>

Não

A definição do campo de esquema do item da tabela ao inserir dados no DashVector. O resultado após a transformação do conteúdo do evento deve estar no formato JSON.

array<object>

Não

Name

object

Não

O nome da propriedade.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome da propriedade.

content

Type

object

Não

O tipo de propriedade do DashVector.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tipo de propriedade do DashVector.

STRING

Value

object

Não

O valor da propriedade.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

JSONPATH

Template

string

Não

O estilo do modelo.

${content}

Value

string

Não

O valor da propriedade.

$.data.content

InstanceId

string

Não

O ID da instância.

vrs-cn-lbj3ru1***

Network

string

Não

O tipo de rede. Valores válidos:

  • PrivateNetwork

  • PublicNetwork

PublicNetwork

Operation

string

Não

O tipo de operação do banco de dados DashVector. Valores válidos:

  • Delete

  • Upsert

Upsert

Partition

object

Não

A partição. Valor padrão: default.

Form

string

Não

O formato de transformação. Valores válidos:

  • JSONPATH

  • CONSTANT

CONSTANT

Template

string

Não

O estilo do modelo.

${partition}

Value

string

Não

O valor.

  • Se Form for CONSTANT: o valor constante.

  • Se Form for JSONPATH: o conteúdo extraído usando JSONPath.

Nota

O campo Value não pode exceder 10.240 caracteres.

default

PrimaryKeyId

object

Não

O ID da chave primária usado ao inserir ou excluir um registro. Se este campo não for especificado, um ID de chave primária aleatório será usado.

Form

string

Não

O formato de transformação. Valores válidos:

  • JSONPATH

  • TEMPLATE

JSONPATH

Template

string

Não

O modelo de ID da chave primária. Este campo é obrigatório apenas quando Form está definido como TEMPLATE.

${ID}

Value

string

Não

O valor.

  • Se Form for JSONPATH: o conteúdo extraído usando JSONPath.

  • Se Form for TEMPLATE: a variável do modelo.

Nota

O campo Value não pode exceder 10.240 caracteres.

$.data.requestId

Vector

object

Não

O vetor do registro do DashVector a ser inserido.

Form

string

Não

O formato de transformação.

JSONPATH

Template

string

Não

O estilo do modelo.

${vector}

Value

string

Não

O conteúdo extraído usando JSONPath.

Nota

O campo Value não pode exceder 10.240 caracteres.

$.data.messageBody

SinkDataHubParameters

object

Não

Os parâmetros do sink do DataHub.

Body

object

Não

O modelo de conteúdo do registro para o tipo BLOB.

Form

string

Não

O formato de transformação.

ORIGINAL

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O modelo de conteúdo do registro para o tipo BLOB.

{ "key": "value" }

ContentSchema

object

Não

Os pares chave-valor do log personalizado. Este parâmetro entra em vigor apenas quando ContentType está definido como KeyValue. Cada par chave-valor é representado por Key_n e Value_n.

Form

string

Não

O estilo do modelo.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O valor antes da conversão.

{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}

ContentType

object

Não

O formato dos dados. Você pode selecionar o formato padrão ou especificar pares chave-valor. Valores válidos:

  • JSON

  • KeyValue

Form

string

Não

O formato de transformação.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O valor antes da conversão.

JSON

Project

object

Não

O nome do projeto do DataHub.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome do projeto do DataHub.

demo-project

RoleName

object

Não

O nome da função da tarefa.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome da função da tarefa.

test-role

Topic

object

Não

O nome do tópico do DataHub.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome do tópico do DataHub.

demo-topic

TopicSchema

object

Não

O esquema de conteúdo do tópico para o tipo TUPLE.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

{"k1":"${k1}","k2":"${k2}"}

Value

string

Não

O esquema de conteúdo do tópico para o tipo TUPLE.

{"k1":"value1","k2":"value2"}

TopicType

object

Não

O tipo de tópico. Valores válidos:

  • TUPLE

  • BLOB

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tipo de tópico. Valores válidos:

  • TUPLE

  • BLOB

TUPLE

SinkDataWorksTriggerParameters SinkDataWorksTriggerParameters

Não

Os parâmetros de entrega para o gatilho do DataWorks.

SinkDorisParameters

object

Não

O tipo de origem do evento.

BeHttpEndpoint

object

Não

O endpoint HTTP público para BE.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O endpoint HTTP público para BE.

"BeHttpEndpoint"

Body

object

Não

O conteúdo da mensagem.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O conteúdo da mensagem.

{ "key": "value" }

Database

object

Não

O banco de dados.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O banco de dados.

"Database"

FeHttpEndpoint

object

Não

O endpoint HTTP para FE.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O endpoint HTTP para FE.

"FeHttpEndpoint"

NetworkType

object

Não

O tipo de rede.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tipo de rede.

PublicNetwork

Password

object

Não

A senha.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

A senha.

yourPassword

QueryEndpoint

object

Não

O endpoint do MySQL.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O endpoint do MySQL.

"QueryEndpoint"

SecurityGroupId

object

Não

O ID do grupo de segurança.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID do grupo de segurança.

sg-mw43*****

Table

object

Não

A tabela de destino.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

A tabela de destino.

"Table"

UserName

object

Não

O nome de usuário.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome de usuário.

"UserName"

VSwitchIds

object

Não

Os IDs dos vSwitches.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

Os IDs dos vSwitches.

vbr-8vb835n3zf9shwl****mp

VpcId

object

Não

O ID da VPC.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID da VPC.

i-2ze7u5i17mbqtx1p****

SinkEventHouseParameters

object

Não

O nome do destino do evento.

CatalogName

string

Não

O nome do catálogo.

demo

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.

ColumnName

string

Não

O nome da coluna.

age

ColumnType

string

Não

O tipo da coluna.

text

ColumnValue

object

Não

A regra de extração para o valor da coluna.

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}!

Value

string

Não

O caminho de extração, como $.data.value.name.

$.data.value

NamespaceName

string

Não

O namespace da tabela de destino.

name1

SinkFcParameters

object

Não

O destino da função.

Body

object

Não

O corpo do conteúdo enviado para a função.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

Concurrency

object

Não

A simultaneidade de entrega. O valor mínimo é 1.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

A simultaneidade de entrega. O valor mínimo é 1.

1

DataFormat

object

Não

A regra de transformação de formato para o conteúdo do evento.

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

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

FunctionName

object

Não

O nome da função.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O nome da função.

mFunction

InvocationType

object

Não

O tipo de invocação. Valores válidos:

  • Sync: invocação síncrona

  • Async: invocação assíncrona

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O tipo de invocação.

Async

Qualifier

object

Não

O alias do serviço ao qual a função pertence.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O alias do serviço ao qual a função pertence.

LATEST

ServiceName

object

Não

O nome do serviço.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O nome do serviço.

myService

SinkFnfParameters

object

Não

Os parâmetros do destino Fnf.

ExecutionName

object

Não

O nome da execução.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome da execução.

123

FlowName

object

Não

O nome do fluxo.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome do fluxo.

test-streaming-fnf

Input

object

Não

As informações de entrada para a execução.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

As informações de entrada para a execução.

123

RoleName

object

Não

A configuração da função.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

A configuração da função.

Al****FNF-x****

SinkHttpsParameters SinkHttpsParameters

Não

Os parâmetros do destino HTTPS.

SinkKafkaParameters

object

Não

Os parâmetros do Kafka do sink.

Acks

object

Não

O modo de confirmação para gravação de dados 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 falhar.\n- acks=all: Uma resposta é retornada somente após o nó primário gravar os dados com sucesso e os nós secundários sincronizarem os dados. Este modo oferece menor desempenho, mas garante maior segurança dos dados. Os dados são perdidos somente se os nós primário e secundários falharem.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O modo de confirmação para gravação de dados 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 falhar.\n- acks=all: Uma resposta é retornada somente após o nó primário gravar os dados com sucesso e os nós secundários sincronizarem os dados. Este modo oferece menor desempenho, mas garante maior segurança dos dados. Os dados são perdidos somente se os nós primário e secundários falharem.

1

CompressionType

string

Não

O tipo de compactação.

"CompressionType"

DynamicTopic

object

Não

A política de roteamento de tópico de destino para mensagens. Se os parâmetros Topic e DynamicTopic forem especificados, o valor do parâmetro DynamicTopic terá precedência. 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

Não

O tipo de conversão. Valores válidos:\n- CONSTANT: Um valor fixo.\n- JSONPATH: Extraído da mensagem upstream com base no caminho especificado.

CONSTANT

Template

string

Não

O modelo.

The template string, if any

Value

string

Não

O valor.

"DynamicTopic"

Headers

object

Não

Os metadados adicionais para mensagens do Kafka.

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}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

InstanceId

object

Não

O tipo de serviço de destino é o Message Queue for Apache Kafka. Especifique o ID da instância da fila de mensagens (MSMQ).

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O ID da instância.

Defaut_1283278472_s****

Key

object

Não

O identificador da mensagem.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O identificador da mensagem.

key

Topic

object

Não

O nome do tópico.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O nome do tópico.

test

Value

object

Não

O conteúdo do corpo da mensagem.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

SinkKnowledgeBaseParameters SinkKnowledgeBaseParameters

Não

Os parâmetros de entrega da base de conhecimento.

SinkMNSParameters

object

Não

O destino de evento do Simple Message Queue (anteriormente MNS), que é um serviço MSMQ.

Body

object

Não

O conteúdo da mensagem.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

IsBase64Encode

object

Não

Especifica se a codificação Base64 deve ser ativada.

Form

string

Não

O formato de transformação de evento. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

Ativa a codificação Base64.

true

QueueName

object

Não

O tipo de serviço de destino é o Simple Message Queue (anteriormente MNS), um serviço MSMQ.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O nome da fila no Simple Message Queue (anteriormente MNS), um serviço MSMQ.

MyQueue

SinkMQTTParameters SinkMQTTParameters

Não

Os parâmetros de entrega MQTT.

SinkOSSParameters SinkOSSParameters

Não

Os parâmetros de entrega do Object Storage Service (OSS).

SinkOpenSourceRabbitMQParameters

object

Não

Os parâmetros do sink do RabbitMQ autogerenciado.

AuthType

string

Não

O tipo de autenticação. Valores válidos:

  • ACL

  • None

ACL

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

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor dos dados brutos.

{"key": "value"}

Endpoint

string

Não

O endpoint.

192.168.1.1:9876

Exchange

string

Não

O nome do exchange no RabbitMQ. Este parâmetro tem efeito apenas quando TargetType é definido como Exchange.

my-exchange

MessageId

object

Não

O identificador exclusivo da mensagem.

Form

string

Não

O formato de transformação. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O valor do ID da mensagem.

12345

NetworkType

string

Não

O tipo de rede. Valores válidos:

  • PrivateNetwork

  • PublicNetwork

PublicNetwork

Password

string

Não

A senha usada para acessar a instância do RabbitMQ.

yourPassword

Properties

object

Não

As propriedades adicionais da mensagem.

Form

string

Não

O formato de transformação. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O conteúdo da propriedade.

{"env": "prod"}

QueueName

string

Não

O nome da fila no RabbitMQ. Este parâmetro tem efeito apenas quando TargetType é definido como Queue.

my-queue

RoutingKey

object

Não

A chave de roteamento da mensagem.

Form

string

Não

O formato de transformação. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor da chave de roteamento.

{"Form": "CONSTANT", "Value": "my-routing-key"}

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-uf6of9452b2pba82c ****

TargetType

string

Não

O tipo de destino para entrega de mensagens. Valores válidos:

  • Exchange: As mensagens são roteadas por meio de um exchange.

  • Queue: As mensagens são entregues diretamente a uma fila especificada.

Exchange

Username

string

Não

O nome de usuário usado para acessar a instância do RabbitMQ.

admin

VSwitchIds

string

Não

O ID do vSwitch.

vsw-uf6of9452b2pba82c ****

VirtualHostName

string

Não

O nome do host virtual no RabbitMQ.

Vhost1

VpcId

string

Não

O ID da VPC.

vpc-uf6of9452b2pba82c ****

SinkPrometheusParameters

object

Não

Os parâmetros do sink do Prometheus.

AuthorizationType

object

Não

O método de autenticação.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O método de autenticação.

BASIC_AUTH

Data

object

Não

O conteúdo da métrica.

Form

string

Não

O formato de transformação. Valor padrão: JSONPATH.

JSONPATH

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O conteúdo da métrica.

$.data

HeaderParameters

object

Não

A estrutura de dados dos parâmetros do cabeçalho da solicitação.

Form

string

Não

O formato de transformação. Valores válidos:

  • JSONPATH: JSONPATH.

  • CONSTANT: CONSTANT.

  • TEMPLATE: TEMPLATE.

TEMPLATE

Template

string

Não

O modelo de cabeçalho de solicitação HTTP. Este parâmetro é obrigatório quando Form é definido como TEMPLATE. O conteúdo do evento transformado deve estar no formato JSON.

{ "user_name":"${name}" }

Value

string

Não

  • CONSTANT: Um valor constante.

  • JSONPATH: O conteúdo extraído usando JSONPath.

  • TEMPLATE: Uma variável de modelo.

Nota: O campo Value não pode exceder 10.240 caracteres de comprimento.

name

NetworkType

object

Não

O tipo de rede.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tipo de rede. Valores válidos:

  • PublicNetwork

  • PrivateNetwork

PrivateNetwork

Password

object

Não

A senha.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

A senha.

abc

SecurityGroupId

object

Não

O ID do grupo de segurança.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID do grupo de segurança.

sg-mw43*****

URL

object

Não

A URL de Remote Write do Prometheus.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

A URL de Remote Write do Prometheus.

https://cn-hangzhou.arms.aliyuncs.com/prometheus/167275****/c5b7faeb2e8994641*****d5c559f/cn-hangzhou/api/v3/write

Username

object

Não

O nome de usuário.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome de usuário.

***admin

VSwitchId

object

Não

O ID do vSwitch.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID do vSwitch.

vsw-dwaafds****

VpcId

object

Não

O ID da VPC.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID da VPC.

vpc-adw1awdw*****

SinkRabbitMQMetaParameters SinkRabbitMQMetaParameters

Não

Os parâmetros de entrega de metadados para o Message Queue for RabbitMQ.

SinkRabbitMQMsgSyncParameters SinkRabbitMQMsgSyncParameters

Não

Os parâmetros de entrega de sincronização de mensagens para o Message Queue for RabbitMQ.

SinkRabbitMQParameters

object

Não

Os parâmetros do sink do ApsaraMQ for RabbitMQ.

Body

object

Não

O conteúdo da mensagem.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

Exchange

object

Não

O modo de exchange. Este parâmetro é obrigatório apenas quando o parâmetro TargetType está definido como Exchange.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O nome do exchange na instância do Message Queue for RabbitMQ.

a_exchange

InstanceId

object

Não

O tipo de serviço de destino é o Message Queue for RabbitMQ.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O ID da instância do Message Queue for RabbitMQ.

amqp-cn-2r42e73o****

MessageId

object

Não

O ID da mensagem.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

NetworkType

object

Não

O tipo de rede usado para conectar à instância do ApsaraMQ for RabbitMQ de destino. Se você definir este parâmetro como PrivateNetwork, também deverá configurar os parâmetros VpcId, VSwitchIds e SecurityGroupId. Ao atualizar um fluxo de eventos e desejar manter a configuração de rede privada original, você deve incluir esses parâmetros de rede.

Form

string

Não

O método de atribuição de parâmetro. Defina este parâmetro como CONSTANT para usar um valor fixo.

CONSTANT

Template

string

Não

O conteúdo do modelo. Este parâmetro de rede usa uma configuração de valor fixo e não realiza conversão de modelo. Você não precisa especificar este campo.

The value of ${key} is ${value}!

Value

string

Não

O tipo de rede usado para conectar à instância do ApsaraMQ for RabbitMQ de destino. Valores válidos:

  • PublicNetwork: a Internet.

  • PrivateNetwork: uma VPC.

PrivateNetwork

Properties

object

Não

As propriedades do filtro.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

QueueName

object

Não

O modo de fila. Este parâmetro é obrigatório apenas quando o parâmetro TargetType está definido como Queue.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O nome da fila na instância.

MyQueue

RoutingKey

object

Não

A regra de roteamento da mensagem. Este parâmetro é obrigatório apenas quando o parâmetro TargetType está definido como Exchange.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

A regra de roteamento da mensagem.

housekeeping

SecurityGroupId

object

Não

O grupo de segurança usado para conectar à instância do ApsaraMQ for RabbitMQ de destino. Este parâmetro é obrigatório quando o parâmetro NetworkType.Value está definido como PrivateNetwork.

Form

string

Não

O método de atribuição de parâmetro. Defina este parâmetro como CONSTANT para usar um valor fixo.

CONSTANT

Template

string

Não

O conteúdo do modelo. Este parâmetro de rede usa uma configuração de valor fixo e não realiza conversão de modelo. Você não precisa especificar este campo.

The value of ${key} is ${value}!

Value

string

Não

O ID do grupo de segurança usado para conectar à instância do ApsaraMQ for RabbitMQ de destino.

sg-bp1xxxxxxxxxxxx

TargetType

object

Não

O tipo de destino.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O tipo de destino. Valores válidos:

  • Exchange: o modo de exchange.

  • Queue: o modo de fila.

Exchange/Queue

VSwitchIds

object

Não

Os vSwitches usados para conectar à instância do ApsaraMQ for RabbitMQ de destino. Este parâmetro é obrigatório quando o parâmetro NetworkType.Value está definido como PrivateNetwork.

Form

string

Não

O método de atribuição de parâmetro. Defina este parâmetro como CONSTANT para usar um valor fixo.

CONSTANT

Template

string

Não

O conteúdo do modelo. Este parâmetro de rede usa uma configuração de valor fixo e não realiza conversão de modelo. Você não precisa especificar este campo.

The value of ${key} is ${value}!

Value

string

Não

Os IDs dos vSwitches usados para conectar à instância do ApsaraMQ for RabbitMQ de destino. Separe vários IDs de vSwitch com vírgulas (,).

vsw-bp1xxxxxxxxxxxx,vsw-bp1yyyyyyyyyyyy

VirtualHostName

object

Não

O nome do vhost na instância do Message Queue for RabbitMQ.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome do vhost na instância do Message Queue for RabbitMQ.

rabbit-host

VpcId

object

Não

A VPC onde a instância do ApsaraMQ for RabbitMQ de destino reside. Este parâmetro é obrigatório quando o parâmetro NetworkType.Value está definido como PrivateNetwork.

Form

string

Não

O método de atribuição de parâmetro. Defina este parâmetro como CONSTANT para usar um valor fixo.

CONSTANT

Template

string

Não

O conteúdo do modelo. Este parâmetro de rede usa uma configuração de valor fixo e não realiza conversão de modelo. Você não precisa especificar este campo.

The value of ${key} is ${value}!

Value

string

Não

O ID da VPC onde a instância do ApsaraMQ for RabbitMQ de destino reside.

vpc-bp1xxxxxxxxxxxx

SinkRocketMQCheckpointParameters

object

Não

O tipo de origem do evento.

ConsumeTimestamp

object

Não

O timestamp em que a mensagem é consumida.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O timestamp.

1570761026400

Group

object

Não

O ID do grupo de consumidores.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O grupo de consumidores.

GID_EVENTBRIDGE_1736234******

InstanceId

string

Não

O ID da instância.

MQ_INST_164901546557****_BAAN****

InstanceType

string

Não

O tipo de instância. Valores válidos:

  • Cloud_4: uma instância do ApsaraMQ for RocketMQ 4.0.

  • Cloud_5: uma instância do ApsaraMQ for RocketMQ 5.0.

Cloud_4

Topic

object

Não

O tópico da instância do Message Queue for RocketMQ.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome do tópico na instância do Message Queue for RocketMQ.

Mytopic

SinkRocketMQParameters

object

Não

Os parâmetros de destino da mensagem MSMQ RocketMQ.

Body

object

Não

O conteúdo da mensagem.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

DeliveryOrderType

object

Não

O tipo de ordem de entrega da mensagem. Opcional. Valor padrão: Concurrently.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tipo de ordem de entrega. Valores válidos:

  • Orderly: Entrega ordenada.

  • Concurrently: Entrega concorrente.

Concurrently

InstanceEndpoint

object

Não

O endpoint da instância.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O endpoint da instância.

vbr-8vbsvkkbpf3vb0zef****

InstanceId

object

Não

O ID da instância. O tipo de serviço de destino é a mensagem MSMQ RocketMQ.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O ID da instância da mensagem MSMQ RocketMQ.

MQ_INST_164901546557****_BAAN****

InstancePassword

object

Não

A senha da instância.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

A senha da instância.

admin****

InstanceType

object

Não

O tipo de instância.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tipo de instância. Valores válidos:

  • Cloud_4: Instância do ApsaraMQ for RocketMQ 4.0. Este é o valor padrão.

  • Cloud_5: Instância do ApsaraMQ for RocketMQ 5.0.

  • SelfBuilt: Cluster do Apache RocketMQ autogerenciado.

Cloud_4

InstanceUsername

object

Não

O nome de usuário da instância.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O nome de usuário da instância.

admin

Keys

object

Não

As propriedades do filtro.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

Network

object

Não

O tipo de rede. Valores válidos:

  • PublicNetwork

  • PrivateNetwork

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tipo de rede. Valores válidos:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

Properties

object

Não

As propriedades do filtro.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

SecurityGroupId

object

Não

O ID do grupo de segurança.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID do grupo de segurança.

b4bf375515f6440f942e3a20c33d****

ShardingKey

object

Não

A chave de sharding da mensagem.

Nota

Quando DeliveryOrderType é definido como Orderly, este parâmetro especifica a regra de transformação de conteúdo de evento para a propriedade ShardingKey ao gravar mensagens no serviço downstream. Se a origem for o RocketMQ, ShardingKey pode estar vazio. Nesse caso, a chave de sharding da mensagem é gerada pela concatenação do BrokerName e do QueueId upstream.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O valor da chave de sharding.

order_id

Tags

object

Não

As propriedades do filtro.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

Topic

object

Não

O tópico da instância de mensagem MSMQ RocketMQ.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O tópico da instância de mensagem MSMQ RocketMQ.

Mytopic

VSwitchIds

object

Não

O ID do vSwitch.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID do vSwitch.

vbr-8vb835n3zf9shwl****mp

VpcId

object

Não

O ID da VPC.

Form

string

Não

O formato de transformação de evento. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O ID da VPC.

vbr-8vb835n3zf9shwlvb****

SinkSLSParameters

object

Não

Os parâmetros do sink do Simple Log Service (SLS).

Body

object

Não

O conteúdo enviado para o SLS.

Form

string

Não

O formato de transformação.

TEMPLATE

Template

string

Não

O estilo do modelo.

The value of ${key} is ${value}!

Value

string

Não

O valor antes da conversão.

{ "key": "value" }

ContentSchema

object

Não

Os pares de chave-valor personalizados para logs. Este parâmetro entra em vigor apenas quando ContentType está definido como KeyValue. Cada par de chave-valor é representado por Key_n e Value_n.

Form

string

Não

O formato de transformação.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

Os pares de chave-valor personalizados.

{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}

ContentType

object

Não

O formato de dados do SLS. Valores válidos:\n- JSON\n- KeyValue.

Form

string

Não

O formato de transformação.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O formato de dados do SLS.

JSON

LogStore

object

Não

O Logstore do SLS.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O Logstore do SLS.

test-logstore

Project

object

Não

O projeto do SLS.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O projeto do SLS.

test-project

RoleName

object

Não

Ao conceder autorização ao barramento de eventos EventBridge para usar esta função para ler o conteúdo de log do SLS, você deve atender às seguintes condições: ao criar a função para o serviço no console do Resource Access Management (RAM), você deve selecionar Alibaba Cloud Service e definir o serviço confiável como o barramento de eventos.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

Ao conceder autorização ao barramento de eventos EventBridge para usar esta função para ler o conteúdo de log do SLS, você deve atender às seguintes condições: ao criar a função para o serviço no console do Resource Access Management (RAM), você deve selecionar Alibaba Cloud Service e definir o serviço confiável como o barramento de eventos.

testRole

Topic

object

Não

O tópico do log. Isso corresponde ao campo reservado topic no SLS.

Form

string

Não

O formato de conversão. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

The template string, if any

Value

string

Não

O tópico do log. Isso corresponde ao campo reservado topic no SLS.

testTopic

RunOptions

object

Não

Os parâmetros do ambiente de execução.

BatchWindow

object

Não

A janela de lote.

CountBasedWindow

integer

Não

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 é atendida para qualquer uma das janelas.

100

TimeBasedWindow

integer

Não

A janela de tempo máxima em segundos para acumular eventos. 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 é atendida para qualquer uma das janelas.

10

BusinessOption

object

Não

As opções de negócio.

BusinessMode

string

Não

O modo de negócio.

"BusinessMode"

MaxCapacityUnitCount

integer

Não

O número máximo de unidades de capacidade.

10

MinCapacityUnitCount

integer

Não

O número mínimo de unidades de capacidade.

1

DeadLetterQueue

object

Não

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

Não

O ARN da fila de mensagens mortas.

acs:ram::131733464781****:role/rdstoecsassumekms

Network

string

Não

O tipo de rede da fila de mensagens mortas. Valores válidos:\n- PrivateNetwork\n- PublicNetwork.

PrivateNetwork

SecurityGroupId

string

Não

O ID do grupo de segurança da instância da fila de mensagens mortas.

sg-2vcgdxz7o1n9zapp****

VSwitchIds

string

Não

O ID do vSwitch no qual a fila de mensagens mortas reside.

vsw-m5ev8asdc6h12345****

VpcId

string

Não

O ID da VPC na qual a fila de mensagens mortas reside.

vpc-2zehizpoendb3****

ErrorsTolerance

string

Não

A política de tolerância a erros. Valores válidos:\n- NONE: Sem tolerância a erros.\n- ALL: Tolerância a todos os erros.

ALL

MaximumTasks

integer

Não

O número de tarefas simultâneas.

2

RetryStrategy

object

Não

A política de nova tentativa usada quando um evento falha ao ser enviado.

MaximumEventAgeInSeconds

integer

Não

O tempo máximo de nova tentativa.

512

MaximumRetryAttempts

integer

Não

O número máximo de tentativas.

2

PushRetryStrategy

string

Não

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.

BACKOFF_RETRY

Throttling

integer

Não

O valor de limitação.

100

Transforms

array<object>

Não

As configurações de transformação.

object

Não

O ARN do serviço em nuvem, como o ARN de uma função no Function Compute.

AiChunkTransformParameters AiChunkTransformParameters

Não

Os parâmetros de fragmentação de texto local de IA.

AiClassifyTransformParameters AiClassifyTransformParameters

Não

Os parâmetros de classificação de texto de IA.

AiEmbedTransformParameters AiEmbedTransformParameters

Não

Os parâmetros de embedding de IA.

AiExtractTransformParameters AiExtractTransformParameters

Não

Os parâmetros de extração de informações de IA.

AiFilterTransformParameters AiFilterTransformParameters

Não

Os parâmetros de filtragem condicional de IA.

AiPrepSearchTransformParameters AiPrepSearchTransformParameters

Não

Os parâmetros de fragmentação semântica de IA.

AiRedactTransformParameters AiRedactTransformParameters

Não

Os parâmetros de mascaramento de dados de IA.

AiSentimentAnalysisTransformParameters AiSentimentAnalysisTransformParameters

Não

Os parâmetros de análise de sentimentos de IA.

AiSummarizeTransformParameters AiSummarizeTransformParameters

Não

Os parâmetros de sumarização de IA.

AiTranslateTransformParameters AiTranslateTransformParameters

Não

Os parâmetros de tradução de IA.

Arn

string

Não

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

Não

Os parâmetros de transformação do agente do Model Studio.

DashScopeTransformParameters DashScopeTransformParameters

Não

Os parâmetros de transformação do modelo DashScope.

Elementos de resposta

Elemento

Tipo

Descrição

Exemplo

object

As informações da resposta.

Code

string

O código de resposta. O valor Success indica que a solicitação foi bem-sucedida. Outros valores indicam códigos de erro. Para mais informações, consulte Códigos de erro.

Success

Message

string

A mensagem de erro.

The name [xxxx] of event streaming in request is already exist!

RequestId

string

O identificador exclusivo gerado pelo Alibaba Cloud para a solicitação.

0FDD73AA-7A2D-5BD4-B4C0-88AFEBF5F0F5

Success

boolean

Indica se a operação foi bem-sucedida. O valor true indica que a operação foi bem-sucedida.

true

Exemplos

Resposta de sucesso

JSON formato

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