1.报错
pymongo.errors.ServerSelectionTimeoutError: s-8vbb1ba3aa777034.mongodb.zhangbei.rds.aliyuncs.com:3717: timed out,s-8vbb2c155414aa44.mongodb.zhangbei.rds.aliyuncs.com:3717: timed out
原因:库里面没有对应的collection!!
2.代码
def init_motor(datas):
# def init_motor():
db_url='127.0.0.1'
# db_url='172.26.178.248'
# db_url='39.99.160.162'
# db_port=27017
# 外网
# db_url="mongodb://datagroup:datagroup123@s-8vbb2c155414aa44-pub.mongodb.zhangbei.rds.aliyuncs.com:3717/admin"
# 内网
db_url="mongodb://datagroup:datagroup123@s-8vbb2c155414aa44.mongodb.zhangbei.rds.aliyuncs.com:3717,s-8vbb1ba3aa777034.mongodb.zhangbei.rds.aliyuncs.com:3717/admin"
db_name="chain_info_btc"
db_collection="new_transaction_test"
# db_collection="tmp_new_tx"
# db_collection="entity"
# 建立连接
# 同步pymongo
client=pymongo.MongoClient(db_url)
# 连接某个库名字
db=client[db_name][db_collection]
# 查询测试
# 查询一个collection
# num=db.estimated_document_count()
# print(num)
# 批量插入
try:
db.insert_many(datas, ordered=False, bypass_document_validation=True)
except BulkWriteError as e:
logger.error(e.details)
网友评论