Ekt*_*ney 7 python amazon-rds amazon-kinesis
我正在尝试通过 kinesis 数据流传输 rds,但它给了我这个错误:
botocore.exceptions.ClientError:调用 PutRecord 操作时发生错误 (ValidationException):检测到 1 个验证错误:值 'arn:aws:kinesis:us-west-2:xxxxxxxxxx:stream/rds-temp-leads-stream' at 'streamName' 未能满足约束:成员必须满足正则表达式模式:[a-zA-Z0-9_.-]+
我能做些什么来解决这个问题?
import json
import boto3
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)
def main():
mysql = {
"host": "",
"port":,
"user": "",
"passwd": "",
"db": ""}
kinesis = boto3.client("kinesis", region_name = 'us-west-2')
stream = BinLogStreamReader(
connection_settings = mysql,
server_id=100,
blocking = True,
log_file='mysql-bin.000003',
resume_stream=True,
only_events=[DeleteRowsEvent, WriteRowsEvent, UpdateRowsEvent])
for binlogevent in stream:
for row in binlogevent.rows:
print row
event = {"schema": binlogevent.schema,
"table": binlogevent.table,
"type": type(binlogevent).__name__,
"row": row
}
kinesis.put_record(StreamName="jhgjh", Data=json.dumps(event, cls=DateTimeEncoder), PartitionKey="default")
#print json.dumps(event)
if __name__ == "__main__":
main()
Run Code Online (Sandbox Code Playgroud)
从流名称中删除“arn:aws:kinesis:us-west-2:xxxxxxxxxx:stream/rds-temp-leads-stream”。只需将流的名称放在那里,例如“rds-temp-leads-stream”
| 归档时间: |
|
| 查看次数: |
24230 次 |
| 最近记录: |