验证错误............：“streamName”处的值“<TestStream>”未能满足约束

Question

尝试将流数据从 MYSQL 迁移到 Kinesis 时出错。帮我解决这个问题。

botocore.exceptions.ClientError：调用 PutRecord 操作时发生错误 (ValidationException)：检测到 1 个验证错误：“streamName”处的值“”未能满足约束：成员必须满足正则表达式模式：[a-zA- Z0-9_.-]+

import json
import boto3
import pymysql
import socket,array
import pandas as pd
from datetime import datetime
from pymysqlreplication import BinLogStreamReader
from pymysqlreplication.row_event import (
    DeleteRowsEvent,
    UpdateRowsEvent,
    WriteRowsEvent,
)
class DateTimeEncoder(json.JSONEncoder):
    def default(self, o):
        if isinstance(o, datetime):
            return o.isoformat()

        return json.JSONEncoder.default(self, o)

connection = {
    "host": "127.0.0.1",
    "port": 3306,
    "user": "root",
    "passwd": "root"}

def main():
  kinesis = boto3.client("kinesis",region_name='ap-south-1')
  stream = BinLogStreamReader(
            connection_settings=connection,
            only_events=[DeleteRowsEvent, WriteRowsEvent, UpdateRowsEvent],
            server_id=100,
            blocking=True,
            log_file='mysql-bin.000003',
            resume_stream=True,
        )
  for binlogevent in stream:
    for row in binlogevent.rows:
      event = {"schema": binlogevent.schema,
      "table": binlogevent.table,
      "type": type(binlogevent).__name__,
      "row": row
      }       
      kinesis.put_record(StreamName="<MysqlKinesisStream>", Data=json.dumps(event,cls=DateTimeEncoder), 
PartitionKey="default",)
      print (json.dumps(event))
if __name__ == "__main__":
   main()

Answer 1

这意味着名称 "<TestStream>" 是无效的 Kinesis 流名称。使用您在 AWS 中创建的 Kinesis 流名称。

Kinesis 名称必须匹配正则表达式模式[a-zA-Z0-9_.-]+