Cria um fluxo de eventos.
Descrição da operação
Cria um fluxo de eventos.
Experimente agora
Testar
Autorização RAM
|
Ação |
Nível de acesso |
Tipo de recurso |
Chave de condição |
Ação dependente |
|
eventbridge:CreateEventStreaming |
create |
*EventStreaming.
|
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 |
| 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 |
| 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:
|
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 |
| 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 |
| 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. |
|
|
| LoadFormat |
string |
Não |
O carregador de documentos. Valores válidos:
|
TextLoader |
| LoadMode |
string |
Não |
O modo de carregamento de dados. Valores válidos:
Valores válidos:
|
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 |
| 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 |
| 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 |
| 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 |
| 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:
Valores válidos:
|
PrivateNetwork |
| Offset |
string |
Não |
O offset de consumo de mensagens. Valores válidos:
|
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:
|
PublicNetwork |
| Operation |
string |
Não |
O tipo de operação do banco de dados DashVector. Valores válidos:
|
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:
|
CONSTANT |
| Template |
string |
Não |
O estilo do modelo. |
${partition} |
| Value |
string |
Não |
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 |
| 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 |
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 |
| 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:
|
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 |
| 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 |
| 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 |
| 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 |
| 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 |
| 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 |
| 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:
|
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 |
| 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:
|
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 |
| 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:
|
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 |
| 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 |
| 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 |
| 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 |
| 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:
|
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 |
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 |
| Template |
string |
Não |
O estilo do modelo. |
Template string (if any) |
| Value |
string |
Não |
O tipo de rede. Valores válidos:
|
PrivateNetwork |
| Password |
object |
Não |
A senha. |
|
| Form |
string |
Não |
O formato de conversão. Valor padrão: CONSTANT. Valores válidos:
|
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 |
| 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 |
| 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 |
| 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 |
| 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 |
| 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/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 |
| 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 |
| 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:
|
|
| 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:
|
|
| 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:
|
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 |
| 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 |
| 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.