尝试将流数据从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()
这意味着名称"
运动学名称必须与正则表达式模式匹配
[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: 运行时,在它返回 编辑: 新的部署阶段是: 我有这个应用程序创建使用: 组使用: