Todos os produtos
Search
Central de documentação

EventBridge:CreateEventStreaming

Última atualização: Oct 21, 2026

Cria um fluxo de eventos.

Descrição da operação

Cria 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:CreateEventStreaming

create

*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 este parâmetro não for especificado, todos os eventos serão correspondidos.

{ "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 especificar exatamente uma origem.

SourceApacheKafkaParameters

object

Não

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

Bootstraps

string

Não

Os endpoints.

"Bootstraps"

ConsumerGroup

string

Não

O nome do grupo de consumidores.

DEFAULT_GROUP

NetworkType

string

Não

O tipo de rede da instância do Kafka.

PrivateNetwork

OffsetReset

string

Não

A política de redefinição de offset. Valores válidos:

  • latest: O sistema lê dados a partir do offset mais recente.

  • earliest: O sistema lê dados a partir do offset 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 SASL da instância do Kafka.

"SaslMechanism"

SaslPassword

string

Não

A senha SASL da instância do Kafka.

yourPassword

SaslUser

string

Não

O nome de usuário SASL da instância do Kafka.

"SaslUser"

SecurityGroupId

string

Não

O ID do grupo de segurança ao qual a origem do Kafka pertence.

sg-bp1iv19sp1msc7zot4****

SecurityProtocol

string

Não

O tipo de protocolo de segurança da instância do Kafka. Valores válidos:

  • SASL_SSL

  • PLAINTEXT

  • 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 estiver protegida por uma senha (ou seja, o arquivo PEM contém a tag 'Proc-Type: 4,ENCRYPTED' ou 'ENCRYPTED'), você deve fornecer a senha de descriptografia. Deixe este parâmetro vazio se a chave privada não estiver criptografada. Nota: esta senha é usada apenas para descriptografar a chave privada e é irrelevante para a 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 pelo certificado da CA intermediária, e o certificado da CA raiz é opcional). Nota: certifique-se de que o conteúdo de cada arquivo PEM comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----'. Concatene-os antes da codificação Base64.

"SslKeystoreCertificateChain"

SslKeystoreKey

object

Não

[Obrigatório para autenticação bidirecional] O objeto de configuração de 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 KMS que armazena a chave privada do cliente. Exemplo de formato: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. Como obter: visualize as informações de ARN da chave correspondente no console KMS.

"KmsArn"

KmsSecretValueKey

string

Não

[Modo KMS KV] O nome da chave no segredo KMS. Se o segredo armazenado no KMS usar uma estrutura de par chave-valor (KV), especifique este parâmetro para indicar a chave correspondente à chave privada SSL. Exemplo: se o segredo KMS for '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', insira 'ssl_keystore_key'. Se o segredo KMS usar o 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 confiável do servidor Kafka. Este parâmetro é usado para autenticar a validade do certificado SSL do broker Kafka e evitar ataques do tipo man-in-the-middle. Requisitos de formato: codificação Base64 em formato PEM, que geralmente contém o certificado da CA do servidor Kafka ou o próprio certificado do servidor. Exemplo: execute a codificação Base64 no conteúdo do arquivo PEM do certificado da 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 assinatura da CA que emitiu o certificado.

"SslTruststoreCertificates"

Topic

string

Não

O nome do tópico.

LTC_CACHE_PRD

VSwitchIds

string

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

vsw-bp179l3llg3jjxwrq72****

ValueDataType

string

Não

O tipo de dados. Valores válidos:

  • Text

  • Binary

  • Json

JSON

VpcId

string

Não

O ID da VPC à qual a origem do Kafka pertence.

vpc-8vblalsi0vbhizr77****

SourceApacheRocketMQCheckpointParameters

object

Não

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

InstanceEndpoint

string

Não

O endpoint da instância.

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

InstancePassword

string

Não

A senha da instância.

admin

InstanceUsername

string

Não

O nome de usuário da instância.

admin

NetworkType

string

Não

O tipo de rede.

PrivateNetwork

RegionId

string

Não

O ID da região.

cn-hangzhou

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

Topics

array

Não

Os tópicos de mensagens.

string

Não

Os tópicos de mensagens.

myTopic

VSwitchId

string

Não

O ID do vSwitch.

"VSwitchId"

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

SourceCustomizedKafkaConnectorParameters

object

Não

A origem de eventos do Apache Kafka do conector personalizado.

ConnectorPackageUrl

string

Não

O 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 do Kafka.

{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }

SourceCustomizedKafkaParameters

object

Não

A origem de eventos personalizada do Kafka.

InstanceId

string

Não

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

r-8vb64581862c****

SourceDTSParameters

object

Não

A origem do 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 offset de consumo, que é o carimbo de data e hora em que o cliente SDK consome o primeiro dado. O formato é 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.

HD3

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

Os parâmetros de origem do barramento de eventos.

EventBusName

string

Não

O nome do barramento de eventos.

"EventBusName"

EventRuleName

string

Não

O nome da regra de evento.

"EventRuleName"

SourceFeiShuDocsParameters SourceFeiShuDocsParameters

Não

Os parâmetros de origem do documento do Lark.

SourceJDBCParameters SourceJDBCParameters

Não

Os parâmetros da fonte de dados JDBC.

SourceKafkaParameters

object

Não

Os parâmetros de origem do Kafka.

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.

r-8vb64581862c****

Network

string

Não

A configuração de rede. Valor padrão: Default. Para uma rede VPC, o valor é PublicNetwork.

Default

OffsetReset

string

Não

O offset.

latest

RegionId

string

Não

O ID da região.

cn-hangzhou

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

Topic

string

Não

O nome do tópico.

popvip_center_robot_order

VSwitchIds

string

Não

O ID do vSwitch.

vsw-bp179l3llg3jjxwrq72****

ValueDataType

string

Não

O formato de codificação e decodificação do corpo da mensagem. Valores válidos:

  • JSON

  • Text

  • Binary

JSON

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

SourceMNSParameters

object

Não

Os parâmetros de origem do MNS.

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-beijing

SourceMQTTParameters

object

Não

Os parâmetros de origem do MQTT.

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.

r-bp1b5ncun5lqer****

NetworkType

string

Não

O tipo de rede.

PrivateNetwork

RegionId

string

Não

O ID da região.

cn-shenzhen

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

Topic

string

Não

O tópico da mensagem.

CANAL_VICUTU_UAT

VSwitchIds

string

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

vsw-bp179l3llg3jjxwrq72****

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

SourceMySQLParameters SourceMySQLParameters

Não

Os parâmetros da fonte de dados MySQL.

SourceOSSParameters

object

Não

Os parâmetros de origem de evento do OSS.

BucketName

string

Não

O nome do bucket do Object Storage Service (OSS).

bucket_abc

Delimiter

string

Não

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

\n

FileExtensions

array

Não

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

["pdf","docx"]

string

Não

A extensão de arquivo.

pdf

LoadFormat

string

Não

O carregador de documentos.

Valores válidos:

  • TextLoader :

    TextLoader.

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.

Valores válidos:

  • single :

    single.

  • element :

    element.

single

Prefix

string

Não

O prefixo do caminho do arquivo.

fun/document/

RoleName

string

Não

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

eventbridge_oss_role

SourceOpenSourceRabbitMQParameters

object

Não

Os parâmetros de origem do RabbitMQ autogerenciado.

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

Endpoint

string

Não

O endpoint.

"Endpoint"

NetworkType

string

Não

O tipo de rede.

PrivateNetwork

Password

string

Não

A senha da conta do grupo de consumidores.

admin

QueueName

string

Não

O nome da fila.

queue_api_1642474203601

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

Username

string

Não

A conta do grupo de consumidores.

admin

VSwitchIds

string

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

vsw-bp179l3llg3jjxwrq72****

VirtualHostName

string

Não

O nome do vhost para a instância do RabbitMQ da fila de mensagens MSMQ.

eb-connect

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

SourcePostgreSQLParameters SourcePostgreSQLParameters

Não

Os parâmetros da fonte de dados PostgreSQL.

SourcePrometheusParameters

object

Não

Os parâmetros de origem de evento 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.

"ExternalLabels"

Labels

string

Não

Os rótulos.

__name__=.*

RegionId

string

Não

O ID da região.

cn-hangzhou

RoleName

string

Não

O nome da função do RAM que concede autorização ao barramento de eventos EventBridge para ler logs do Simple Log Service. 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.

eventbridge_oss_role

SourceRabbitMQMetaParameters SourceRabbitMQMetaParameters

Não

Os parâmetros de origem dos metadados do RabbitMQ da fila de mensagens MSMQ.

SourceRabbitMQMsgSyncParameters SourceRabbitMQMsgSyncParameters

Não

Os parâmetros de origem da sincronização de mensagens do RabbitMQ da fila de mensagens MSMQ.

SourceRabbitMQParameters

object

Não

Os parâmetros de origem do RabbitMQ.

InstanceId

string

Não

O ID da instância do RabbitMQ da fila de mensagens MSMQ.

gtm-cn-k2c2yfg****

NetworkType

string

Não

O tipo de rede.

PrivateNetwork

QueueName

string

Não

O nome da fila para a instância do RabbitMQ da fila de mensagens MSMQ.

demo

RegionId

string

Não

O ID da região.

cn-hangzhou

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

VSwitchIds

string

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

vsw-bp179l3llg3jjxwrq72****

VirtualHostName

string

Não

O nome do vhost para a instância do RabbitMQ da fila de mensagens MSMQ.

eb-connect

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

SourceRocketMQCheckpointParameters

object

Não

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

InstanceId

string

Não

O ID da instância.

r-8vb64581862c****

InstanceType

string

Não

O tipo de instância.

Cloud_4

RegionId

string

Não

O ID da região.

cn-hangzhou

Topics

array

Não

Os tópicos de mensagens.

string

Não

Os tópicos de mensagens.

myTopic

SourceRocketMQParameters

object

Não

A 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 filtro de mensagem.

Tag

GroupID

string

Não

O ID do grupo da instância do Message Queue for RocketMQ.

GID_group1

InstanceEndpoint

string

Não

O endpoint da instância.

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

InstanceId

string

Não

A região à qual a instância do Message Queue for RocketMQ pertence.

default_C56C36026****

InstanceNetwork

string

Não

As informações 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

As informações do grupo de segurança da instância.

sg-m5edtu24f12345****

InstanceType

string

Não

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

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

  • Cloud_5: Instância do Alibaba Cloud RocketMQ 5.0.

  • SelfBuilt: Cluster do Apache RocketMQ autogerenciado.

Cloud_4

InstanceUsername

string

Não

O nome de usuário da instância.

admin

InstanceVSwitchIds

string

Não

As informações de vSwitch da instância.

vsw-m5ev8asdc6h123456****

InstanceVpcId

string

Não

As informações de VPC da instância.

vpc-m5e3sv4b12345****

Network

string

Não

O tipo de rede. Valores válidos:

  • PublicNetwork

  • PrivateNetwork

Valores válidos:

  • PrivateNetwork :

    PrivateNetwork.

  • PublicNetwork :

    PublicNetwork.

PrivateNetwork

Offset

string

Não

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

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

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

  • CONSUME_FROM_TIMESTAMP: Consome mensagens a partir do offset em um ponto no tempo especificado. Valor padrão: CONSUME_FROM_LAST_OFFSET.

CONSUMEFROMLAST_OFFSET

RegionId

string

Não

O ID da região.

cn-qingdao

SecurityGroupId

string

Não

O grupo de segurança da tarefa transfronteiriça.

sg-m5edtu24f12345****

Tag

string

Não

A tag de filtro de mensagens.

test

Timestamp

integer

Não

O timestamp. Este parâmetro só entra em vigor quando o parâmetro Offset é definido como CONSUME_FROM_TIMESTAMP.

1670656652009

Topic

string

Não

O tópico do serviço de mensagens.

Topic_publicRule_api_1667273421288

VSwitchIds

string

Não

Os IDs de vSwitch da tarefa transfronteiriça.

vsw-m5ev8asdc6h12345****

VpcId

string

Não

O ID da VPC da tarefa transfronteiriça.

vpc-m5e3sv4b12345****

SourceSLSParameters

object

Não

A origem do Simple Log Service (SLS).

ConsumePosition

string

Não

O offset inicial de consumo. Você pode selecionar o offset mais antigo ou mais recente, que corresponde a begin ou end, respectivamente. Você também pode especificar um ponto no tempo em segundos para iniciar o consumo.

end

LogStore

string

Não

O Logstore do Simple Log Service.

sas-log

Project

string

Não

O projeto do Simple Log Service.

test

RoleName

string

Não

Ao conceder autorização para que o barramento de eventos do EventBridge use 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 o serviço confiável deve ser definido como EventBridge.

testRole

Metadata

string

Não

As configurações JSON comuns do provedor de eventos. Este parâmetro é mutuamente exclusivo com o parâmetro Source.

{"key":"value"}

Sink

object

Não

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

SinkAgentRunParameters SinkAgentRunParameters

Não

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

SinkApacheKafkaParameters

object

Não

As informações de descrição.

Acks

string

Não

O modo de confirmação para gravação no Kafka. Valores válidos:\n- acks=0: Nenhuma resposta do servidor é necessária. Este modo oferece alto desempenho, mas apresenta alto risco de perda de dados.\n- acks=1: Uma resposta é retornada após o nó primário gravar os dados com sucesso. Este modo oferece desempenho moderado e apresenta risco moderado de perda de dados. Os dados podem ser perdidos se o nó primário cair.\n- acks=all: Uma resposta é retornada após o nó primário gravar os dados com sucesso e os nós secundários sincronizarem os dados com sucesso. Este modo oferece menor desempenho, mas maior segurança dos dados. Os dados são perdidos apenas quando os nós primário e secundários caem.

all

Bootstraps

string

Não

O endpoint inicial do cluster Kafka.

"Bootstraps"

CompressionType

string

Não

O tipo de compactação.

"CompressionType"

DynamicTopic

object

Não

Especifica a política de tópico de destino para o roteamento de mensagens. Se os parâmetros Topic e DynamicTopic forem especificados, o valor do parâmetro DynamicTopic terá precedência. Os seguintes dois 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 do upstream com base no caminho.

CONSTANT

Template

string

Não

O modelo.

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.

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.

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.

Template string (if any)

Value

string

Não

O tipo de rede.

PrivateNetwork

SaslMechanism

string

Não

O mecanismo SASL da instância do Kafka.

"SaslMechanism"

SaslPassword

string

Não

A senha SASL da instância do Kafka.

yourPassword

SaslUser

string

Não

O nome de usuário SASL da instância 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.

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 estiver protegida por uma senha (ou seja, o arquivo PEM contém a tag 'Proc-Type: 4,ENCRYPTED' ou 'ENCRYPTED'), você deve fornecer a senha de descriptografia. Deixe este parâmetro vazio se a chave privada não estiver criptografada. Nota: esta senha é usada apenas para descriptografar a chave privada e é irrelevante para a 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 pelo certificado da CA intermediária, e o certificado da CA raiz é opcional). Nota: certifique-se de que o conteúdo de cada arquivo PEM comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----'. Concatene-os antes da codificação 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 padrão KMS. Você pode usar o KmsArn para especificar o recurso EPS do Key Management Service (KMS) que armazena a chave privada. 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 KMS que armazena a chave privada do cliente. Exemplo de formato: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. Como obter: visualize as informações de ARN da chave correspondente no console KMS.

"KmsArn"

KmsSecretValueKey

string

Não

[Modo KMS KV] O nome da chave no segredo KMS. Se o segredo armazenado no KMS usar uma estrutura de par chave-valor (KV), especifique este parâmetro para indicar a chave correspondente à chave privada SSL. Exemplo: se o segredo KMS for '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', insira 'ssl_keystore_key'. Se o segredo KMS usar o 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 certificado é usado para autenticar a legitimidade 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 CA do servidor Kafka ou o próprio certificado do servidor. Exemplo: Execute a codificação Base64 no conteúdo do arquivo PEM do certificado CA (certifique-se de que o conteúdo comece com '-----BEGIN CERTIFICATE-----' e termine com '-----END CERTIFICATE-----'). Se o Kafka usar um certificado autoassinado, você deve fornecer o certificado CA que emitiu o certificado.

"SslTruststoreCertificates"

Topic

string

Não

O nome do tópico.

LTC_CACHE_PRD

VSwitchIds

object

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

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.

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.

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 e hora do ponto de verificação de consumo.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O carimbo de data e hora.

1670656652009

Group

object

Não

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

Template string (if any)

Value

string

Não

O grupo de consumidores.

"Group"

InstanceEndpoint

string

Não

O endpoint da instância.

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

InstancePassword

string

Não

A senha da instância.

admin

InstanceUsername

string

Não

O nome de usuário da instância.

admin

NetworkType

string

Não

O tipo de rede.

PrivateNetwork

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

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.

Template string (if any)

Value

string

Não

O nome do tópico.

demo-topic

VSwitchId

string

Não

O ID do vSwitch.

"VSwitchId"

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

SinkApiDestinationParameters SinkApiDestinationParameters

Não

Os parâmetros de entrega do 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 analisado a partir do 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 for Apache Kafka.

90be1f96-4229-4535-bb76-34b4f6fb2b71

SinkDashVectorParameters

object

Não

Os parâmetros do sink do DashVector.

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

As definições de campos de esquema para registros inseridos no DashVector. O conteúdo do evento transformado deve estar no formato JSON.

array<object>

Não

A coluna de atributo.

Name

object

Não

O nome do atributo.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O nome do atributo.

content

Type

object

Não

O tipo de atributo do DashVector.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O tipo de atributo do DashVector.

STRING

Value

object

Não

O valor do atributo.

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 do atributo.

$.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 :

    PrivateNetwork.

  • PublicNetwork :

    PublicNetwork.

PublicNetwork

Operation

string

Não

O tipo de operação do banco de dados DashVector.

Valores válidos:

  • Delete :

    Excluir.

  • Upsert :

    Upsert.

Upsert

Partition

object

Não

A partição. O valor padrão é a partição padrão.

Form

string

Não

O formato de transformação.

Valores válidos:

  • JSONPATH :

    JSONPATH.

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

${partition}

Value

string

Não

  • Se Form for CONSTANT: um 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.

Nota

Se você não especificar este campo, um ID de chave primária aleatório será usado.

Form

string

Não

O formato de transformação.

Valores válidos:

  • JSONPATH :

    JSONPATH.

  • TEMPLATE :

    TEMPLATE.

JSONPATH

Template

string

Não

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

${ID}

Value

string

Não

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

  • Se Form for TEMPLATE: uma variável de modelo.

Nota

O campo Value não pode exceder 10.240 caracteres.

$.data.requestId

Vector

object

Não

O vetor do registro inserido no DashVector.

Form

string

Não

O formato de transformação.

Valores válidos:

  • JSONPATH :

    JSONPATH.

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.

Template string (if any)

Value

string

Não

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

{ "key": "value" }

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.

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.

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.

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:\n- TUPLE\n- BLOB.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O tipo de tópico. Valores válidos:\n- TUPLE\n- BLOB.

TUPLE

SinkDataWorksTriggerParameters SinkDataWorksTriggerParameters

Não

Os parâmetros de entrega do 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.

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.

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.

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.

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.

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.

Template string (if any)

Value

string

Não

A senha.

yourPassword

QueryEndpoint

object

Não

O endpoint do protocolo MySQL.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O endpoint do protocolo 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.

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.

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.

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.

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.

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. Valores válidos:\n- ORIGINAL: Evento completo.\n- JSONPATH: Evento parcial.\n- CONSTANT: Constante.\n- TEMPLATE: Modelo.\nPara mais informações, consulte Transformação de eventos.

Valores válidos:

  • JSONPATH :

    JSONPATH.

  • CONSTANT :

    CONSTANT.

  • ORIGINAL :

    ORIGINAL.

  • TEMPLATE :

    TEMPLATE.

TEMPLATE

Template

string

Não

O estilo do modelo.

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

Value

string

Não

O valor antes da transformação.

{ "key": "value" }

Concurrency

object

Não

A concorrência de entrega. O valor mínimo é 1.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

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

Value

string

Não

A concorrência de entrega. O valor mínimo é 1.

1

DataFormat

object

Não

O formato dos dados.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O formato dos dados.

"DataFormat"

FunctionName

object

Não

O nome da função.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    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.

myFunction

InvocationType

object

Não

O tipo de invocação. Valores válidos:\n- Sync: Invocação síncrona.\n- Async: Invocação assíncrona.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    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. Valores válidos:\n- Sync: Invocação síncrona.\n- Async: Invocação assíncrona.

Valores válidos:

  • Async :

    Async.

  • Sync :

    Sync.

Async

Qualifier

object

Não

A versão do serviço.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

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

Value

string

Não

A versão do serviço.

LATEST

ServiceName

object

Não

O nome do serviço.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    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 Sink Fnf.

ExecutionName

object

Não

O nome da execução.

Form

string

Não

O formato de transformação. Valor padrão: CONSTANT. Valores válidos:\n- JSONPATH: Evento parcial.\n- CONSTANT: Constante.\n- TEMPLATE: Modelo.\nPara mais informações, consulte Transformação de eventos.

Valores válidos:

  • JSONPATH :

    JSONPATH.

  • CONSTANT :

    CONSTANT.

  • TEMPLATE :

    TEMPLATE.

CONSTANT

Template

string

Não

O estilo do modelo.

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.

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

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 transformação. Valores válidos:\n- ORIGINAL: Evento completo.\n- JSONPATH: Evento parcial.\n- CONSTANT: Constante.\n- TEMPLATE: Modelo.\nPara mais informações, consulte Transformação de eventos.

Valores válidos:

  • JSONPATH :

    JSONPATH.

  • CONSTANT :

    CONSTANT.

  • ORIGINAL :

    ORIGINAL.

  • TEMPLATE :

    TEMPLATE.

CONSTANT

Template

string

Não

O estilo do modelo.

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.

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

A configuração da função.

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

SinkHttpsParameters SinkHttpsParameters

Não

Os parâmetros de entrega HTTPS.

SinkKafkaParameters

object

Não

Os parâmetros do Kafka do sink.

Acks

object

Não

O modo de confirmação para gravação no Kafka. Valores válidos:\n- acks=0: Nenhuma resposta do servidor é necessária. Este modo oferece alto desempenho, mas apresenta alto risco de perda de dados.\n- acks=1: Uma resposta é retornada após o nó primário gravar os dados com sucesso. Este modo oferece desempenho moderado e apresenta risco moderado de perda de dados. Os dados podem ser perdidos se o nó primário cair.\n- acks=all: Uma resposta é retornada após o nó primário gravar os dados com sucesso e os nós secundários sincronizarem os dados com sucesso. Este modo oferece menor desempenho, mas maior segurança dos dados. Os dados são perdidos apenas quando os nós primário e secundários caem.

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 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 moderado e apresenta risco moderado de perda de dados. Os dados podem ser perdidos se o nó primário cair.\n- acks=all: Uma resposta é retornada após o nó primário gravar os dados com sucesso e os nós secundários sincronizarem os dados com sucesso. Este modo oferece menor desempenho, mas maior segurança dos dados. Os dados são perdidos apenas quando os nós primário e secundários caem.

1

CompressionType

string

Não

O tipo de compactação.

"CompressionType"

DynamicTopic

object

Não

Especifica a política de tópico de destino para o roteamento de mensagens. Se os parâmetros Topic e DynamicTopic forem especificados, o valor do parâmetro DynamicTopic terá precedência. Os seguintes dois 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 do upstream com base no caminho.

CONSTANT

Template

string

Não

O modelo.

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.

Template string (if any)

Value

string

Não

Os cabeçalhos da mensagem.

"Headers"

InstanceId

object

Não

O tipo de serviço de destino é MSMQ para Kafka.

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

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 value of ${key} is ${value}!

Value

string

Não

A chave 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 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 transformação.

{ "key": "value" }

SinkKnowledgeBaseParameters SinkKnowledgeBaseParameters

Não

Os parâmetros de entrega da base de conhecimento.

SinkMNSParameters

object

Não

O destino do evento MNS.

Body

object

Não

O conteúdo da mensagem.

Form

string

Não

O formato de transformação.

Valores válidos:

  • JSONPATH :

    JSONPATH.

  • CONSTANT :

    CONSTANT.

  • TEMPLATE :

    TEMPLATE.

TEMPLATE

Template

string

Não

O estilo do modelo.

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

Value

string

Não

O valor antes da transformação.

{ "key": "value" }

IsBase64Encode

object

Não

Especifica se a codificação Base64 está ativada.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    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 Message Service (MNS).

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

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

Value

string

Não

O nome da fila do Message Service (MNS).

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 para o destino RabbitMQ autogerenciado.

AuthType

string

Não

O tipo de autenticação.

ACL

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.

Template string (if any)

Value

string

Não

O conteúdo da mensagem.

{ "key": "value" }

Endpoint

string

Não

O endpoint.

"Endpoint"

Exchange

string

Não

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

"Exchange"

MessageId

object

Não

O ID da mensagem.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O ID da mensagem.

{ "key": "value" }

NetworkType

string

Não

O tipo de rede.

PrivateNetwork

Password

string

Não

A senha da conta do grupo de consumidores.

admin

Properties

object

Não

As propriedades do filtro.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

As propriedades do filtro.

{ "key": "value" }

QueueName

string

Não

O nome da fila.

queue_api_1642474203601

RoutingKey

object

Não

A regra de roteamento da mensagem. Este parâmetro é obrigatório apenas quando o parâmetro TargetType é 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.

Template string (if any)

Value

string

Não

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

housekeeping

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

TargetType

string

Não

O tipo de destino.

Exchange

Username

string

Não

A conta do grupo de consumidores.

admin

VSwitchIds

string

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

vsw-bp179l3llg3jjxwrq72****

VirtualHostName

string

Não

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

eb-connect

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

SinkPrometheusParameters

object

Não

Os parâmetros do sink do Prometheus.

AuthorizationType

object

Não

O tipo de autenticação.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O tipo de autenticação.

Valores válidos:

  • BASIC_AUTH :

    BASIC_AUTH.

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.

JSAONPATH

Template

string

Não

O estilo do modelo.

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. Especifique este parâmetro quando Form estiver definido como TEMPLATE. O conteúdo do evento transformado deve estar no formato JSON.

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

Value

string

Não

  • Se Form estiver definido como CONSTANT: o valor constante.

  • Se Form estiver definido como JSONPATH: o conteúdo extraído usando JSONPath.

  • Se Form estiver definido como TEMPLATE: a variável do modelo.

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

name

NetworkType

object

Não

O tipo de rede.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O tipo de rede.

Valores válidos:

  • PrivateNetwork :

    PrivateNetwork.

  • PublicNetwork :

    PublicNetwork.

PrivateNetwork

Password

object

Não

A senha.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

A senha.

yourPassword

SecurityGroupId

object

Não

O ID do grupo de segurança.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O ID do grupo de segurança.

sg-mw43*****

URL

object

Não

A URL do Remote Write do Prometheus.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O modelo. Deixe este parâmetro vazio quando Form estiver definido como CONSTANT.

Template string (if any)

Value

string

Não

A URL do 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.

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.

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

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.

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O ID da VPC.

i-2ze7u5i17mbqtx1p****

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 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 transformação.

{ "key": "value" }

Exchange

object

Não

O modo de exchange. Este parâmetro é obrigatório apenas quando o parâmetro TargetType é 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 MSMQ for RabbitMQ.

a_exchange

InstanceId

object

Não

O tipo de serviço de destino é o MSMQ for RabbitMQ.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    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 MSMQ for RabbitMQ.

a5ff91ad4f3f24947887fe184fc2****

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 transformação.

{ "key": "value" }

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.

Template string (if any)

Value

string

Não

O tipo de rede.

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 transformaçã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 é 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 para a mensagem.

housekeeping

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.

Template string (if any)

Value

string

Não

O ID do grupo de segurança.

sg-mw43*****

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: Modo Exchange.

  • Queue: Modo Queue.

Exchange/Queue

VSwitchIds

object

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

vbr-8vb835n3zf9shwl****mp

VirtualHostName

object

Não

O nome do vhost na instância do MSMQ for RabbitMQ.

Form

string

Não

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

Valores válidos:

  • CONSTANT :

    CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O nome do vhost na instância do MSMQ for RabbitMQ.

rabbit-host

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.

Template string (if any)

Value

string

Não

O ID da VPC.

i-2ze7u5i17mbqtx1p****

SinkRocketMQCheckpointParameters

object

Não

O tipo de origem do evento.

ConsumeTimestamp

object

Não

O carimbo de data e hora do ponto de verificação de consumo.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O carimbo de data e hora.

1670656652009

Group

object

Não

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

Template string (if any)

Value

string

Não

O grupo de consumidores.

"Group"

InstanceId

string

Não

O ID da instância.

r-8vb64581862c****

InstanceType

string

Não

O tipo de instância.

Cloud_4

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.

Template string (if any)

Value

string

Não

O nome do tópico.

demo-topic

SinkRocketMQParameters

object

Não

Os parâmetros de destino para o 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 transformação.

{ "key": "value" }

DeliveryOrderType

object

Não

O tipo de ordem de entrega.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O tipo de ordem de entrega.

"DeliveryOrderType"

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.

Template string (if any)

Value

string

Não

O endpoint da instância.

vbr-8vbsvkkbpf3vb0zef****

InstanceId

object

Não

O tipo de serviço de destino é o 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 do 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.

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.

Template string (if any)

Value

string

Não

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

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

  • Cloud_5: Instância do Alibaba Cloud 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.

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 transformaçã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.

Template string (if any)

Value

string

Não

O tipo de rede. Valores válidos:\n- PublicNetwork\n- 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 transformaçã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.

Template string (if any)

Value

string

Não

O ID do grupo de segurança.

b4bf375515f6440f942e3a20c33d****

ShardingKey

object

Não

A chave de sharding.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

A chave de sharding.

"ShardingKey"

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 transformação.

{ "key": "value" }

Topic

object

Não

O tópico da instância do 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 nome do tópico da instância do 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.

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 da transformação do evento. Valor padrão: CONSTANT.

CONSTANT

Template

string

Não

O estilo do modelo.

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 transformação.

{ "key": "value" }

ContentSchema

object

Não

Os pares de chave-valor para logs personalizados. Este parâmetro entra em vigor apenas quando ContentType é definido como KeyValue. Cada par de 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.

Template string (if any)

Value

string

Não

O valor antes da transformação.

{"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:

  • JSON

  • KeyValue

Form

string

Não

O formato de transformação.

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O valor antes da transformação.

JSON

LogStore

object

Não

O Logstore do Simple Log Service.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O Logstore do Simple Log Service.

test-logstore

Project

object

Não

O projeto do Simple Log Service.

Form

string

Não

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

CONSTANT

Template

string

Não

O estilo do modelo.

Template string (if any)

Value

string

Não

O projeto do Simple Log Service.

test-project

RoleName

object

Não

Ao conceder autorização para o 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 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.

Template string (if any)

Value

string

Não

Ao conceder autorização para o 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 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.

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 conter. Quando esse limite é atingido, os dados na janela são enviados para o downstream. Se existirem várias janelas, o envio é acionado quando qualquer janela atinge o limite.

100

TimeBasedWindow

integer

Não

A janela de tempo máxima em segundos para agrupar eventos em lotes. Quando esse limite é atingido, os dados na janela são enviados para o downstream. Se existirem várias janelas, o envio é acionado quando qualquer janela atinge o limite.

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 é 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

A configuração de rede. Valor padrão: Default. Para uma rede VPC, o valor é PublicNetwork.

Default

SecurityGroupId

string

Não

O ID do grupo de segurança.

sg-bp1iv19sp1msc7zot4****

VSwitchIds

string

Não

Os IDs dos vSwitches aos quais a origem do Kafka pertence.

vsw-bp179l3llg3jjxwrq72****

VpcId

string

Não

O ID da VPC.

vpc-8vblalsi0vbhizr77****

ErrorsTolerance

string

Não

A política de tolerância a erros. Valores válidos:

  • NONE: Nenhum erro é tolerado.

  • ALL: Todos os erros são tolerados.

ALL

MaximumTasks

integer

Não

A concorrência.

2

RetryStrategy

object

Não

A política de nova tentativa usada quando o envio de um evento falha.

MaximumEventAgeInSeconds

integer

Não

O tempo máximo de nova tentativa.

512

MaximumRetryAttempts

integer

Não

O número máximo de novas tentativas.

2

PushRetryStrategy

string

Não

A política de nova tentativa. Valores válidos:

  • BACKOFF_RETRY: Nova tentativa com backoff.

  • 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 vetorização 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.

EmbeddingTransformParameters EmbeddingTransformParameters

Não

Os parâmetros de transformação de embedding.

Tags

array<object>

Não

A lista de tags. Você pode especificar até 20 tags.

object

Não

Key

string

Não

A chave da tag.

env

Value

string

Não

O valor da tag.

prod

Elementos de resposta

Elemento

Tipo

Descrição

Exemplo

object

Os parâmetros da solicitação.

Code

string

O código de retorno da API. Valores válidos:

  • Success: A operação foi bem-sucedida.

  • Outros valores: Um código de erro. Para mais informações, consulte Códigos de erro.

Success

Data

object

Os dados retornados.

EventStreamingARN

string

O Alibaba Cloud Resource Name (ARN) do fluxo de eventos.

acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming

Message

string

A mensagem de erro.

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

RequestId

string

O ID da solicitação.

B896B484-F16D-59DE-9E23-DD0E5C36****

Success

boolean

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

true

Exemplos

Resposta de sucesso

JSON formato

{
  "Code": "Success",
  "Data": {
    "EventStreamingARN": "acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming"
  },
  "Message": "O nome [xxxx] do fluxo de eventos na solicitação já existe!",
  "RequestId": "B896B484-F16D-59DE-9E23-DD0E5C36****",
  "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.