EventBridge:GetEventStreaming

Descrição da operação

Autorização RAM

Parâmetros da solicitação

Elementos de resposta

Exemplos

Resposta de sucesso

JSON formato

{
  "Code": "Success",
  "Data": {
    "Description": "RocketMQ-to-RocketMQ",
    "DetailedStatus": {
      "DelayTime": 3,
      "DiffOffset": 0,
      "Extensions": {
        "test": "test",
        "test2": 1
      },
      "TPS": 5
    },
    "EventStreamingName": "rocketmq-sync",
    "FilterPattern": "{\n\"source\": [\n{\n\"prefix\": \"acs:mns\"\n}\n],\n\"type\": [\n{\n\"prefix\": \"mns:Queue\"\n}\n],\n\"subject\": [\n{\n\"prefix\": \"acs:mns:cn-hangzhou:123456789098****:queues/zeus\"\n}\n]\n}",
    "Metadata": "{\"key\":\"value\"}",
    "RunOptions": {
      "BatchWindow": {
        "CountBasedWindow": 100,
        "TimeBasedWindow": 10
      },
      "BusinessOption": {
        "BusinessMode": "\"BusinessMode\"",
        "MaxCapacityUnitCount": 10,
        "MinCapacityUnitCount": 1
      },
      "DeadLetterQueue": {
        "Arn": "acs:ram::155020394332****:role/edskmstoecs",
        "Network": "PrivateNetwork",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
        "VSwitchIds": "vsw-m5ev8asdc6h12345****",
        "VpcId": "vpc-2zehizpoendb3****"
      },
      "ErrorsTolerance": "ALL",
      "MaximumTasks": 2,
      "RetryStrategy": {
        "MaximumEventAgeInSeconds": 512,
        "MaximumRetryAttempts": 2,
        "PushRetryStrategy": "BACKOFF_RETRY"
      },
      "Throttling": 100
    },
    "Sink": {
      "SinkAgentRunParameters": {
        "AgentRuntimeName": "agent-demo-example",
        "Body": {
          "Form": "ORIGINAL",
          "Template": "The value of ${key} is ${value}!",
          "Value": "$"
        },
        "EndpointName": "default",
        "RoleName": "example-agent-role",
        "Timeout": "30000"
      },
      "SinkApacheKafkaParameters": {
        "Acks": "all",
        "Bootstraps": "\"Bootstraps\"",
        "CompressionType": "\"CompressionType\"",
        "DynamicTopic": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"DynamicTopic\""
        },
        "Headers": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"Headers\""
        },
        "Key": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "key"
        },
        "NetworkType": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "PrivateNetwork"
        },
        "SaslMechanism": "\"SaslMechanism\"",
        "SaslPassword": "yourPassword",
        "SaslUser": "\"SaslUser\"",
        "SecurityGroupId": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "sg-mw43*****"
        },
        "SecurityProtocol": "SASL_SSL",
        "SslKeyPassword": "yourPassword",
        "SslKeystoreCertificateChain": "\"SslKeystoreCertificateChain\"",
        "SslKeystoreKey": {
          "KmsArn": "\"KmsArn\"",
          "KmsSecretValueKey": "\"KmsSecretValueKey\""
        },
        "SslTruststoreCertificates": "\"SslTruststoreCertificates\"",
        "Topic": "LTC_CACHE_PRD",
        "VSwitchIds": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "vbr-8vb835n3zf9shwl****mp\n"
        },
        "Value": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "$.data.content"
        },
        "VpcId": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "i-2ze7u5i17mbqtx1p****"
        }
      },
      "SinkApacheRocketMQCheckpointParameters": {
        "ConsumeTimestamp": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "1570761026400"
        },
        "Group": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "GID_EVENTBRIDGE_1736234******\n"
        },
        "InstanceEndpoint": "192.168.1.1:9876",
        "InstancePassword": "yourPassword",
        "InstanceUsername": "admin",
        "NetworkType": "PrivateNetwork",
        "SecurityGroupId": "sg-2ze5bmpw6adn0q******",
        "Topic": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "Mytopic"
        },
        "VSwitchId": "vsw-uf62oqt1twuevrt******",
        "VpcId": "vpc-2zeccak5pb0j3ay******"
      },
      "SinkApiDestinationParameters": {
        "BodyParameters": {
          "Form": "TEMPLATE",
          "Template": "{\"message\":\"${message}\"}",
          "Value": "{\"message\":\"$.data.message\"}"
        },
        "HeaderParameters": {
          "Form": "TEMPLATE",
          "Template": "{\"${headerName1}\":\"${headerValue1}\"}",
          "Value": "{\"headerName1\":\"X-Example\",\"headerValue1\":\"example-value\"}"
        },
        "Name": "example-api-destination",
        "QueryStringParameters": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Timeout": 0
      },
      "SinkBaiLianParameters": {
        "After": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "example"
        },
        "ApplicationType": "KnowledgeBase",
        "Before": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "example"
        },
        "Context": "",
        "Extend": "",
        "Offset": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "example"
        },
        "Op": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "example"
        },
        "Partition": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "example"
        },
        "WorkspaceId": "llm-a1b2c3d4e5f6g7h8"
      },
      "SinkCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV******\"",
        "ConnectorParameters": {
          "Config": {
            "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
            "tasks.max": "1",
            "topics": "sourceA,sourceB"
          },
          "Name": "mongo-sink"
        },
        "WorkerParameters": {
          "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
          "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
          "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
          "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
          "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
          "bootstrap.servers": "alikafka-post:9092"
        }
      },
      "SinkCustomizedKafkaParameters": {
        "InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb****"
      },
      "SinkDashVectorParameters": {
        "ApiKey": "Q34nExQH7sQ****",
        "Collection": "collection1",
        "DashVectorSchemaParameters": [
          {
            "Name": {
              "Form": "CONSTANT",
              "Template": "The template string, if any",
              "Value": "content"
            },
            "Type": {
              "Form": "CONSTANT",
              "Template": "The template string, if any",
              "Value": "STRING"
            },
            "Value": {
              "Form": "JSONPATH",
              "Template": "${content}",
              "Value": "$.data.content"
            }
          }
        ],
        "InstanceId": "vrs-cn-lbj3ru1***",
        "Network": "PublicNetwork",
        "Operation": "Upsert",
        "Partition": {
          "Form": "CONSTANT",
          "Template": "${partition}",
          "Value": "default"
        },
        "PrimaryKeyId": {
          "Form": "JSONPATH",
          "Template": "${ID}",
          "Value": "$.data.requestId"
        },
        "Vector": {
          "Form": "JSONPATH",
          "Template": "${vector}",
          "Value": "$.data.messageBody"
        }
      },
      "SinkDataHubParameters": {
        "Body": {
          "Form": "ORIGINAL",
          "Template": "The template string, if any",
          "Value": "{\n  \"key\": \"value\"\n}"
        },
        "Project": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "demo-project\n"
        },
        "RoleName": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "test-role"
        },
        "Topic": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "demo-topic\n"
        },
        "TopicSchema": {
          "Form": "TEMPLATE",
          "Template": "{\"k1\":\"${k1}\",\"k2\":\"${k2}\"}",
          "Value": "{\"k1\":\"value1\",\"k2\":\"value2\"}"
        },
        "TopicType": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "TUPLE\n"
        }
      },
      "SinkDataWorksTriggerParameters": {
        "Enable": "true"
      },
      "SinkDorisParameters": {
        "BeHttpEndpoint": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"BeHttpEndpoint\""
        },
        "Body": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "{\n  \"key\": \"value\"\n}"
        },
        "Database": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"Database\""
        },
        "FeHttpEndpoint": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"FeHttpEndpoint\""
        },
        "NetworkType": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "PublicNetwork"
        },
        "Password": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "yourPassword"
        },
        "QueryEndpoint": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"QueryEndpoint\""
        },
        "SecurityGroupId": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "sg-mw43*****"
        },
        "Table": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"Table\""
        },
        "UserName": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"UserName\""
        },
        "VSwitchIds": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "vbr-8vb835n3zf9shwl****mp\n"
        },
        "VpcId": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "i-2ze7u5i17mbqtx1p****"
        }
      },
      "SinkFcParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Concurrency": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "1"
        },
        "DataFormat": {
          "Form": "JSONPATH",
          "Template": "$.data.key",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "FunctionName": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "mFunction"
        },
        "InvocationType": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "Async"
        },
        "Qualifier": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "LATEST"
        },
        "ServiceName": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "myService"
        }
      },
      "SinkFnfParameters": {
        "ExecutionName": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "123"
        },
        "FlowName": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "test-streaming-fnf"
        },
        "Input": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "123"
        },
        "RoleName": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "Al****FNF-x****"
        }
      },
      "SinkHttpsParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "{\"message\":\"${message}\"}",
          "Value": "{\"message\":\"$.data.message\"}"
        },
        "Method": "POST",
        "NetworkType": "PublicNetwork",
        "SecurityGroupId": "",
        "Token": "",
        "URL": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "https://example.com/events"
        },
        "VSwitchIds": "",
        "VpcId": ""
      },
      "SinkKafkaParameters": {
        "Acks": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "1"
        },
        "CompressionType": "\"CompressionType\"",
        "DynamicTopic": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "\"DynamicTopic\""
        },
        "Headers": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}\n\n"
        },
        "InstanceId": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "Defaut_1283278472_s****"
        },
        "Key": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "key"
        },
        "Topic": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "test"
        },
        "Value": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        }
      },
      "SinkKnowledgeBaseParameters": {
        "Catalog": "my_catalog",
        "KnowledgeBaseName": "my-knowledge-base",
        "Namespace": "my_namespace"
      },
      "SinkMNSParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "IsBase64Encode": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "true"
        },
        "QueueName": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "MyQueue"
        }
      },
      "SinkMQTTParameters": {
        "InstanceId": "mqtt-cn-a1b2c3d4e5f",
        "Mqtt5UserProperty": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "ParentTopic": "example-topic",
        "Payload": {
          "Form": "ORIGINAL",
          "Template": "",
          "Value": ""
        },
        "SubTopic": {
          "Form": "",
          "Template": "",
          "Value": ""
        }
      },
      "SinkOSSParameters": {
        "BucketName": "test",
        "CompressionType": "gzip",
        "ContentTransform": {
          "Form": "JSONPATH",
          "Template": "",
          "Value": "$.data.message"
        },
        "Endpoint": "oss-cn-hangzhou-internal.aliyuncs.com",
        "PathFormat": "/EB-test/",
        "RegionId": "cn-hangzhou",
        "RoleArn": "acs:ram::1234567890123456:role/example-eventbridge-role",
        "RotateIntervalMs": "60000",
        "RotateSizeBytes": "1048576",
        "SSLEnabled": false,
        "TaskConcurrency": "1",
        "TimeZone": "UTC+8:00"
      },
      "SinkOpenSourceRabbitMQParameters": {
        "AuthType": "ACL",
        "Body": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\"key\": \"value\"}"
        },
        "Endpoint": "192.168.1.1:9876",
        "Exchange": "my-exchange",
        "MessageId": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "12345"
        },
        "NetworkType": "PublicNetwork\n",
        "Password": "yourPassword",
        "Properties": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\"env\": \"prod\"}"
        },
        "QueueName": "my-queue",
        "RoutingKey": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\"Form\": \"CONSTANT\", \"Value\": \"my-routing-key\"}\n"
        },
        "SecurityGroupId": "sg-uf6of9452b2pba82c ****",
        "TargetType": "Exchange",
        "Username": "admin",
        "VSwitchIds": "vsw-uf6of9452b2pba82c ****",
        "VirtualHostName": "vhost1",
        "VpcId": "vpc-uf6of9452b2pba82c ****"
      },
      "SinkRabbitMQMetaParameters": {
        "Endpoint": "rabbitmq-cn-a1b2c3d4e5f-cn-hangzhou-vpc.amqp.aliyuncs.com",
        "InstanceId": "rabbitmq-cn-a1b2c3d4e5f",
        "InstanceType": "Cloud",
        "NetworkType": "PrivateNetwork",
        "Password": "",
        "SecurityGroupId": "sg-a1b2c3d4e5f6g7h8i9j0",
        "Username": "admin",
        "VSwitchIds": "vsw-a1b2c3d4e5f6g7h8i9j0k",
        "VirtualHostName": "test-001",
        "VpcId": "vpc-a1b2c3d4e5f6g7h8i9j0k"
      },
      "SinkRabbitMQMsgSyncParameters": {
        "Body": {
          "Form": "JSONPATH",
          "Template": "",
          "Value": "$.data.body"
        },
        "Endpoint": "",
        "Exchange": {
          "Form": "JSONPATH",
          "Template": "",
          "Value": "$.data.exchange"
        },
        "InstanceId": "rabbitmq-cn-a1b2c3d4e5f",
        "InstanceType": "Cloud",
        "MaxHops": "1",
        "MessageId": {
          "Form": "JSONPATH",
          "Template": "",
          "Value": "$.data.messageId"
        },
        "NetworkType": "PrivateNetwork",
        "Password": "",
        "Properties": {
          "Form": "JSONPATH",
          "Template": "",
          "Value": "$.data.properties"
        },
        "RoutingKey": {
          "Form": "JSONPATH",
          "Template": "",
          "Value": "$.data.routingKey"
        },
        "SecurityGroupId": "sg-a1b2c3d4e5f6g7h8i9j0",
        "Username": "admin",
        "VSwitchIds": "vsw-a1b2c3d4e5f6g7h8i9j0k",
        "VirtualHostName": "test-001",
        "VpcId": "vpc-a1b2c3d4e5f6g7h8i9j0k"
      },
      "SinkRabbitMQParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Exchange": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "a_exchange"
        },
        "InstanceId": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "e5c9b727-e06c-4d7e-84d5-f8ce644e****"
        },
        "MessageId": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Properties": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "QueueName": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "MyQueue"
        },
        "RoutingKey": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "housekeeping"
        },
        "TargetType": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "Exchange/Queue"
        },
        "VirtualHostName": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "rabbit-host\n"
        }
      },
      "SinkRocketMQCheckpointParameters": {
        "ConsumeTimestamp": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "1570761026400"
        },
        "Group": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "GID_EVENTBRIDGE_1736234******"
        },
        "InstanceId": "MQ_INST_164901546557****_BAAN****",
        "InstanceType": "Cloud_4",
        "Topic": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "Mytopic"
        }
      },
      "SinkRocketMQParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "DeliveryOrderType": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "Concurrently"
        },
        "InstanceEndpoint": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "vbr-8vbsvkkbpf3vb0zef****\n"
        },
        "InstanceId": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "MQ_INST_164901546557****_BAAN****"
        },
        "InstancePassword": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "admin****\n"
        },
        "InstanceType": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "Cloud_4\n"
        },
        "InstanceUsername": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "admin\n"
        },
        "Keys": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Network": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "PublicNetwork\n"
        },
        "Properties": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "SecurityGroupId": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "b4bf375515f6440f942e3a20c33d****\n"
        },
        "ShardingKey": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "order_id"
        },
        "Tags": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Topic": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "Mytopic"
        },
        "VSwitchIds": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "vbr-8vb835n3zf9shwl****mp\n"
        },
        "VpcId": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "vbr-8vb835n3zf9shwlvb****\n"
        }
      },
      "SinkSLSParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "ContentSchema": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "{\"Key_1\":{\"form\":\"CONSTANT\",\"value\":\"demoKey\"},\"Value_1\":{\"form\":\"JSONPATH\",\"value\":\"$.data.value\"}}"
        },
        "ContentType": {
          "Form": "CONSTANT\n",
          "Template": "The template string, if any",
          "Value": "JSON\n"
        },
        "LogStore": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "test-logstore"
        },
        "Project": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "test-project\n"
        },
        "RoleName": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "testRole"
        },
        "Topic": {
          "Form": "CONSTANT",
          "Template": "The template string, if any",
          "Value": "testTopic"
        }
      }
    },
    "Source": {
      "SourceApacheKafkaParameters": {
        "Bootstraps": "\"Bootstraps\"",
        "ConsumerGroup": "DEFAULT_GROUP",
        "NetworkType": "PrivateNetwork",
        "OffsetReset": "latest",
        "SaslMechanism": "\"SaslMechanism\"",
        "SaslPassword": "yourPassword",
        "SaslUser": "\"SaslUser\"",
        "SecurityGroupId": "sg-bp1iv19sp1msc7zot4****",
        "SecurityProtocol": "SASL_SSL",
        "SslKeyPassword": "yourPassword",
        "SslKeystoreCertificateChain": "\"SslKeystoreCertificateChain\"",
        "SslKeystoreKey": {
          "KmsArn": "\"KmsArn\"",
          "KmsSecretValueKey": "\"KmsSecretValueKey\""
        },
        "SslTruststoreCertificates": "\"SslTruststoreCertificates\"",
        "Topic": "LTC_CACHE_PRD",
        "VSwitchIds": "vsw-bp179l3llg3jjxwrq72****",
        "ValueDataType": "JSON",
        "VpcId": "vpc-8vblalsi0vbhizr77****"
      },
      "SourceApacheRocketMQCheckpointParameters": {
        "InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
        "InstanceId": "MQ_INST_164901546557****_BAAN****",
        "InstancePassword": "123456",
        "InstanceUsername": "admin",
        "NetworkType": "PrivateNetwork",
        "RegionId": "cn-hangzhou\n",
        "SecurityGroupId": "sg-mw43*****",
        "Topics": [
          "[\"Topic_1\",\"Topic_2\"]"
        ],
        "VSwitchId": "vsw-dwaafds****",
        "VpcId": "vpc-adw1awdw*****"
      },
      "SourceCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ\"",
        "ConnectorParameters": {
          "Config": {
            "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
            "tasks.max": "1",
            "topics": "sourceA,sourceB"
          },
          "Name": "test-name\n"
        },
        "WorkerParameters": {
          "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
          "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
          "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
          "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
          "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
          "bootstrap.servers": "alikafka-post:9092"
        }
      },
      "SourceCustomizedKafkaParameters": {
        "InstanceId": "r-8vb64581862c****\n"
      },
      "SourceDTSParameters": {
        "BrokerUrl": "\"BrokerUrl\"",
        "InitCheckPoint": "1620962769",
        "Password": "admin****",
        "Sid": "HD1",
        "TaskId": "f86e5814-b223-482c-b768-3b873297****",
        "Topic": "TP_TEST_UNDERWRITE_ISSUE",
        "Username": "admin"
      },
      "SourceEventBusParameters": {
        "EventBusName": "demo",
        "EventRuleName": "test"
      },
      "SourceFeiShuDocsParameters": {
        "AppId": "cli_a946c046xxxx",
        "AppSecret": "yO3hEYiSjkBVxxxx",
        "KnowledgeSpaceName": "Centro de Documentação do Produto",
        "LoadMode": "single"
      },
      "SourceJDBCParameters": {
        "BatchSize": 1000,
        "CustomQuery": "",
        "IncrementingColumn": "",
        "JdbcUrl": "jdbc:mysql://host:3306/database",
        "Network": "PublicNetwork",
        "Password": "",
        "PollingInterval": 60,
        "QueryMode": "bulk",
        "QueryTimeout": 30,
        "SecurityGroupId": "sg-a1b2c3d4e5f6g7h8i9j0",
        "TableName": "example_table",
        "TimestampColumn": "",
        "Username": "example_user",
        "VSwitchIds": "vsw-a1b2c3d4e5f6g7h8i9j0k",
        "VpcId": "vpc-a1b2c3d4e5f6g7h8i9j0k"
      },
      "SourceKafkaParameters": {
        "ConsumerGroup": "GID_TEST",
        "InstanceId": "i-bp1fbtrnqmjvgq66****",
        "Network": "Default",
        "OffsetReset": "latest",
        "RegionId": "cn-hangzhou",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
        "Topic": "topic_empower_1642473600414",
        "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc****",
        "ValueDataType": "Text",
        "VpcId": "vpc-2zehizpoendb3****"
      },
      "SourceMNSParameters": {
        "IsBase64Decode": true,
        "QueueName": "demo",
        "RegionId": "cn-hangzhou"
      },
      "SourceMQTTParameters": {
        "BodyDataType": "JSON",
        "InstanceId": "i-2ze06wqdwk0uq14k****",
        "NetworkType": "PrivateNetwork",
        "RegionId": "cn-shanghai",
        "SecurityGroupId": "sg-bp1iv19sp1msc7zot4****",
        "Topic": "TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel",
        "VSwitchIds": "vsw-bp179l3llg3jjxwrq72****",
        "VpcId": "vpc-8vblalsi0vbhizr77****"
      },
      "SourceMySQLParameters": {
        "DatabaseName": "database1",
        "HostName": "rm-bp1vxxx.mysql.rds.aliyuncs.com",
        "IncludeSchemaChanges": "false",
        "NetworkType": "PrivateNetwork",
        "Password": "",
        "Port": 80,
        "RegionId": "cn-hangzhou",
        "SecurityGroupId": "sg-a1b2c3d4e5f6g7h8i9j0",
        "SnapshotMode": "when_needed",
        "TableNames": "database1.table1",
        "User": "example_user",
        "VSwitchIds": "[vsw-a1b2c3d4e5f6g7h8i9j0k]",
        "VpcId": "vpc-a1b2c3d4e5f6g7h8i9j0k"
      },
      "SourceOSSParameters": {
        "BucketName": "bucket_abc\n",
        "Delimiter": "\\n\n",
        "LoadFormat": "TextLoader\n",
        "LoadMode": "single\n",
        "Prefix": "fun/document/\n",
        "RoleName": "eventbridge_oss_role\n"
      },
      "SourceOpenSourceRabbitMQParameters": {
        "AuthType": "ACL",
        "BodyDataType": "Json",
        "Endpoint": "192.168.1.100:5672",
        "NetworkType": "PrivateNetwork\n",
        "Password": "yourPassword",
        "QueueName": "demo",
        "SecurityGroupId": "sg-2ze65razphjfz3******",
        "Username": "admin",
        "VSwitchIds": "vsw-uf65zhil5oukof5******",
        "VirtualHostName": "eb-connect",
        "VpcId": "vpc-bp1vllc1lnw1v657******"
      },
      "SourcePostgreSQLParameters": {
        "DatabaseName": "analytics_db",
        "HostName": "pgm-bp1xxxxx.pg.rds.aliyuncs.com",
        "NetworkType": "",
        "Password": "",
        "Port": 5432,
        "RegionId": "",
        "SchemaName": "",
        "SecurityGroupId": "",
        "SnapshotMode": "",
        "TableNames": "",
        "User": "readonly_user",
        "VSwitchIds": "",
        "VpcId": ""
      },
      "SourcePrometheusParameters": {
        "ClusterId": "c83555068b6******ad213f565f209\n",
        "DataType": "Json",
        "ExternalLabels": "{\"env\":\"test\"}",
        "Labels": "__name__=.*\n",
        "RegionId": "cn-hangzhou",
        "RoleName": "test-role"
      },
      "SourceRabbitMQMetaParameters": {
        "Endpoint": "rabbitmq-cn-a1b2c3d4e5f-cn-hangzhou-vpc.amqp.aliyuncs.com",
        "InnerNameSuffix": "rabbitmq-cn-a1b2c3d4e5f_example_123e4567-e89b-42d3-a456-426614174000",
        "InstanceId": "rabbitmq-cn-a1b2c3d4e5f",
        "InstanceType": "Cloud",
        "MaxHops": "1",
        "NetworkType": "",
        "OrderConsume": "false",
        "Password": "",
        "Regex": "^example_.*",
        "SecurityGroupId": "",
        "SyncMetaType": "",
        "Username": "admin",
        "VSwitchIds": "",
        "VirtualHostName": "test-001",
        "VpcId": ""
      },
      "SourceRabbitMQMsgSyncParameters": {
        "BodyDataType": "",
        "CloudMigrationTaskId": "123e4567-e89b-42d3-a456-426614174000",
        "DstClusterHost": "",
        "DstClusterType": "Cloud",
        "Endpoint": "192.0.2.10",
        "InstanceId": "rabbitmq-cn-a1b2c3d4e5f",
        "InstanceType": "SelfBuilt",
        "NetworkType": "PrivateNetwork",
        "OrderConsume": "",
        "Password": "",
        "PrefetchCount": "",
        "Regex": "",
        "SecurityGroupId": "sg-a1b2c3d4e5f6g7h8i9j0",
        "SrcClusterHost": "",
        "SrcClusterType": "SelfBuilt",
        "SyncMetaType": "4",
        "Username": "admin",
        "VSwitchIds": "vsw-a1b2c3d4e5f6g7h8i9j0k",
        "VirtualHostName": "test-001",
        "VpcId": "vpc-a1b2c3d4e5f6g7h8i9j0k"
      },
      "SourceRabbitMQParameters": {
        "InstanceId": "i-f8z9a9mcgwri1c1i****",
        "QueueName": "comp",
        "RegionId": "cn-hangzhou",
        "VirtualHostName": "eb-connect"
      },
      "SourceRocketMQCheckpointParameters": {
        "InstanceId": "rmp-cn-jte3w******\n",
        "InstanceType": "Cloud_4",
        "RegionId": "cn-hangzhou",
        "Topics": [
          "opic_add_anima"
        ]
      },
      "SourceRocketMQParameters": {
        "AuthType": "ACL",
        "BodyDataType": "Json",
        "FilterSql": "index > 10",
        "FilterType": "Tag\n",
        "GroupID": "GID_group1",
        "InstanceEndpoint": "reg****-vpc.cn-zhangjiakou.aliyuncs.com\n",
        "InstanceId": "i-f8zbher64dlm58pl****",
        "InstanceNetwork": "PublicNetwork",
        "InstancePassword": "xxxa",
        "InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
        "InstanceType": "Cloud_4\n",
        "InstanceUsername": "xxxa",
        "InstanceVSwitchIds": "vsw-m5ev8asdc6h12****\n",
        "InstanceVpcId": "vpc-m5e3sv4b12345****\n",
        "Network": "PublicNetwork",
        "Offset": "CONSUMEFROMLASTOFFSET",
        "RegionId": "cn-hangzhou",
        "SecurityGroupId": "sg-m5edtu24f12345****\n",
        "Tag": "v1",
        "Timestamp": 1636597951964,
        "Topic": "topic_add_anima",
        "VSwitchIds": "vsw-m5ev8asdc6h12345****\n",
        "VpcId": "vpc-m5e3sv4b12345****\n"
      },
      "SourceSLSParameters": {
        "ConsumePosition": "begin",
        "ConsumerGroup": "go-dts-shelf-group",
        "LogStore": "waf-logstore",
        "Project": "dmmzk",
        "RoleName": "testRole"
      }
    },
    "Status": "RUNNING",
    "Transforms": [
      {
        "AiChunkTransformParameters": {
          "ChunkingType": "recursive_character",
          "InputField": {
            "Form": "JSONPATH",
            "Value": "$.data.message"
          },
          "MaxOverlapSize": 10,
          "MaxSegmentSize": 1000,
          "StepName": "chunks",
          "Unpack": true
        },
        "AiClassifyTransformParameters": {
          "InputField": {
            "Form": "JSONPATH",
            "Value": "$.data.message"
          },
          "Instruction": "Classifique como bug quando falha ou exceção for mencionada, classifique como outro em caso de incerteza",
          "Labels": [
            "bug"
          ],
          "OutputMode": "single",
          "StepName": "classify_result"
        },
        "AiEmbedTransformParameters": {
          "Dimension": 1024,
          "InputField": {
            "Form": "JSONPATH",
            "Value": "$.data.message"
          },
          "Model": "text-embedding-v4",
          "StepName": "embedding"
        },
        "AiExtractTransformParameters": {
          "ExtractSchema": "{\"type\":\"object\",\"properties\":{\"orderId\":{\"type\":\"string\"},\"amount\":{\"type\":\"number\"}}}",
          "StepName": "extract_result"
        },
        "AiFilterTransformParameters": {
          "Condition": "Reter apenas conteúdo relacionado a reclamações ou reembolsos de usuários",
          "OnMismatch": "discard",
          "StepName": "filter_result"
        },
        "AiPrepSearchTransformParameters": {
          "MaxChunkSize": 20,
          "StepName": "fragmentos"
        },
        "AiRedactTransformParameters": {
          "Entities": [
            "PHONE"
          ],
          "MaskChar": "*",
          "Mode": "mask",
          "StepName": "redact_result"
        },
        "AiSentimentAnalysisTransformParameters": {
          "Aspects": [
            "preço"
          ],
          "StepName": "sentimento"
        },
        "AiSummarizeTransformParameters": {
          "MaxLength": 200,
          "StepName": "resumo"
        },
        "AiTranslateTransformParameters": {
          "SourceLanguage": "zh",
          "StepName": "tradução",
          "TargetLanguage": "en"
        },
        "Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func\n",
        "BaiLianAgentTransformParameters": {
          "ApiKey": "",
          "ApplicationId": "0123456789abcdef0123456789abcdef",
          "Prompt": {
            "Form": "JSONPATH",
            "Template": "",
            "Value": "$.data.message"
          },
          "RequestPerMinute": 0,
          "TokenPerMinute": 0
        },
        "DashScopeTransformParameters": {
          "ApiKey": "",
          "Messages": [
            {
              "Form": "JSONPATH",
              "Role": "USER",
              "Template": "",
              "Value": "$.data.message"
            }
          ],
          "Model": "qwen-max",
          "RequestPerMinute": 1000,
          "StructuredOutputJsonSchema": "{\"type\":\"object\",\"properties\":{\"message\":{\"type\":\"string\"}},\"required\":[\"message\"]}",
          "TokenPerMinute": 0
        }
      }
    ]
  },
  "Message": "The event streaming [xxxx] not existed!",
  "RequestId": "7892F480-58C9-5067-AB35-8A7BEF****",
  "Success": true
}

Códigos de erro

Notas de versão