请帮我生成mongodb连续插入5分钟数据,如果中途断开自动重连的脚本
时间: 2024-09-23 21:05:23 浏览: 49
在Python中,你可以使用`pymongo`库结合`time`模块来实现MongoDB的连续插入,并利用异常处理实现断点重连功能。以下是一个简单的示例脚本:
```python
from pymongo import MongoClient
import time
# 连接配置
client = MongoClient('your_mongodb_connection_string')
db = client['your_database']
collection = db['your_collection']
# 数据准备 (这里仅做演示,实际应用需要替换为你需要的数据)
data_to_insert = [{'timestamp': int(time.time()), 'value': i} for i in range(300)] # 5分钟内599条数据
def insert_data():
try:
for idx, doc in enumerate(data_to_insert):
collection.insert_one(doc)
print(f"Inserted document {idx+1}/{len(data_to_insert)}")
# 每秒插入一条数据
time.sleep(1)
except Exception as e:
print(f"Insertion failed with error: {str(e)}")
# 断开连接后尝试重连
client.close()
client = MongoClient('your_mongodb_connection_string') # 如果网络恢复,重新连接
insert_data() # 从出错的地方开始继续插入
insert_data()
```
记得将`your_mongodb_connection_string`、`your_database`和`your_collection`替换为你的MongoDB集群的实际信息。
阅读全文