当前位置: 首页 > 知识库问答 >
问题:

验证错误............: value''at'stream Name'无法满足约束

欧阳睿范
2023-03-14

尝试将流数据从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()

共有1个答案

桂志诚
2023-03-14

这意味着名称"

运动学名称必须与正则表达式模式匹配[a-zA-Z0-9.-]

 类似资料:
  • 我是新的Cognito。我试图使用Lambda实现AWS Cognito。这是我正在遵循的教程。 这是我在setIdtyPoolId中使用的池ID 这是JUnit测试 这是输出 但是我得到以下错误,因此,语句失败

  • 我正在使用aws api gateway cli测试来测试api网关。API通过cognito用户池进行身份验证,我得到错误: 我不确定要使用哪个值来标识PoolId。我在哪里可以得到这些信息。 尝试类似ARN的失败。格式为的池Id也失败。 示例用法: 导致 根据:https://github.com/AnomalyInnovations/aws-api-gateway-cli-test

  • 问题内容: 好的,因此任务似乎很简单!使用图像(因为它重量轻且安全)来执行一些数据库创建/迁移。我使用的是以下使用的代码在这里: 但是,由于某些错误,未使用安装依赖项。错误如下,我打开的这个问题中提供了完整的日志。 任何帮助表示赞赏。 问题答案: github上的代码包含另一个图像postgres:11-alpine与问题中定义的图像进行比较。 软件包gdal- dev ,geos- dev ,p

  • 嗨大家好, 我正在使用AWS S3 SDK 2.2.8将图像上载到S3。我已经在S3控制台中创建了Bucket。 我使用以下代码段上传文件。 我遇到了以下异常: com.amazonaws.AmazonServiceException:检测到1个验证错误:“accountId”处的值“XXXX-XXXX-XXXX”未能满足约束:成员必须满足正则表达式模式:\d(服务:AmazonCongnitoI

  • 我正在尝试使用AWS CDK创建AWS用户池客户端。我正在使用python代码进行此操作。下面是我的代码- 我已经尝试了不同的选项,作为"TOKEN","令牌","代码","代码","代码"。它仍然不起作用。对于上面的代码,我得到下面的错误- 我不知道这里出了什么问题。我引用此链接是为了:https://docs.aws.amazon.com/AWSCloudFormation/latest/Us

  • 我正在创建一个AWS CodePipeline资源与terraform: 运行时,在它返回 编辑: 新的部署阶段是: 我有这个应用程序创建使用: 组使用: