当我并行运行我的程序(web爬虫)时,我的系统需要异常数量的ram或内存,我还用其他web爬虫进行了测试,我的web爬虫占用的内存是它们的两倍,所以我的问题是如何手动管理python中的内存或ram (如果可能的话) ?。
这是我的密码:-
from bs4 import BeautifulSoup
import requests
import MySQLdb as sql
import time
import warnings
print("starting")
warnings.filterwarnings('ignore')
db = sql.connect("localhost", "root", "arpit", "website")
cursor = db.cursor()
db.autocommit(True)
print("connected to database")
url = "http://www.example.com"
extension = ".com"
print("scrapping url -",url)
r = requests.head(url)
cursor.execute("insert ignore into urls(urls,status,status_code)
values(%s,'pending',%s)", [url, r.status_code])
cursor.execute("select status from urls where status ='pending' limit 1")
result = str(cursor.fetchone())
while (result != "None"):
cursor.execute("select urls from urls where status ='pending' limit 1")
result = str(cursor.fetchone())
s_url = result[2:-3]
cursor.execute("update urls set status = 'done' where urls= %s ", [s_url])
if "https" in url:
url1 = url[12:]
else:
url1 = url[11:]
zone = 0
while True:
try:
r = requests.get(s_url,timeout=60)
break
except:
if s_url == "":
print("done")
break
elif zone >= 4:
print("this url is not valid -",s_url)
break
else:
print("Oops! may be connection was refused. Try again...",s_url)
time.sleep(0.2)
zone = zone + 1
soup = BeautifulSoup(r.content.lower(), 'lxml')
links = soup.find_all("a")
for x in links:
a = x.get('href')
if a is not None and a != "":
if a != "" and a.find("\n") != -1:
a = a[0:a.find("\n")]
if a != "" and a[-1] == "/":
a = a[0:-1]
if a != "":
common_extension = [',',' ',"#",'"','.mp3',"jpg",'.wav','.wma','.7z','.deb','.pkg','.rar','.rpm','.tar','.zip','.bin','.dmg','.iso','.toast','.vcd','.csv','.dat','.log','.mdb','.sav','.sql','.apk','.bat','.exe','.jar','.py','.wsf','.fon','.ttf','.bmp','.gif','.ico','.jpeg','.png','.part','.ppt','.pptx','.class','.cpp','.java','.swift','.ods','.xlr','.xls','.xlsx','.bak','.cab','.cfg','.cpl','.dll','.dmp','.icns','.ini','.lnk','.msi','.sys','.tmp','.3g2','.3gp','.avi','.flv','.h264','.m4v','.mkv','.mov','.mp4','.mpg','.vob','.wmv','.doc','.pdf','.txt']
for ext in common_extension:
if ext in a:
a = ""
break
if a != "":
if a[0:5] == '/http':
a = a[1:]
if a[0:6] == '//http':
a = a[2:]
if a[0:len(url1) + 12] == "https://www." + url1:
cursor.execute("insert ignore into urls(urls,status,status_code) values(%s,'pending',%s)",
[a, r.status_code])
elif a[0:len(url1) + 11] == "http://www." + url1:
cursor.execute("insert ignore into urls(urls,status,status_code) values(%s,'pending',%s)",
[a, r.status_code])
elif a[0:len(url1) + 8] == "https://" + url1:
cursor.execute("insert ignore into urls(urls,status,status_code) values(%s,'pending',%s)",
[url + (a[(a.find(extension + "/")) + 4:]), r.status_code])
elif a[0:len(url1) + 7] == "http://" + url1:
cursor.execute("insert ignore into urls(urls,status,status_code) values(%s,'pending',%s)",
[url + (a[(a.find(extension + "/")) + 4:]), r.status_code])
elif a[0:2] == "//" and a[0:3] != "///" and "." not in a and "http" not in a and "www." not in a:
cursor.execute("insert ignore into urls(urls,status,status_code) values(%s,'pending',%s)",
[url + a[1:], r.status_code])
elif a[0:1] == "/" and a[0:2] != "//" and "." not in a and "http" not in a and "www." not in a:
cursor.execute("insert ignore into urls(urls,status,status_code) values(%s,'pending',%s)",
[url + a[0:], r.status_code])
elif 'http' not in a and 'www.' not in a and "." not in a and a[0] != "/":
cursor.execute("insert ignore into urls(urls,status,status_code) values(%s,'pending',%s)",
[url + '/' + a, r.status_code])
cursor.execute("alter table urls drop id")
cursor.execute("alter table urls add id int primary key not null
auto_increment first")
print("new id is created")发布于 2017-12-24 16:40:43
您的代码内存效率很低,因为您正在进行大量的切片--而且由于字符串是不可变的,所以每个切片都分配一个新对象。
例如:
if a[0:5] == '/http'
a = a[1:]分配一个新字符串,将a从0复制到5,将其与'/http'进行比较,并将其丢弃;此外,如果测试相同,则分配一个新字符串,将a从1复制到该字符串,并丢弃a。如果a是长的,或者如果这种情况经常发生,这可能会成为一个相当大的问题。
查看s --这是一种无需复制字符串的切分字符串的方法(在Python3中使用bytes )。
还有很多其他方法可以优化代码:
common_extension,不如在循环之前定义一次。a[0:5] == '/http',而是使用a.startswith('/http')。url1比较,而是使用一个正则表达式(如re.match('https?://(www\.)?' + re.escape(url1), a) )。
如果要这样做,而不是为每个链接连接'https?://(www\.)?'和re.escape(url1),而是在循环之前做一次,甚至re.compile那里的正则表达式。发布于 2017-12-24 16:33:53
除了创建和删除对象之外,您不能在Python中直接管理内存,因为除了创建和删除对象之外,您不能分配和/or释放内存块。您可以做的是使用工具来了解您的代码中哪些部分使用了多少内存。有关详细信息,请参见,例如,https://www.pluralsight.com/blog/tutorials/how-to-profile-memory-usage-in-python
在python中,限制内存使用的方法显然是不创建大型对象列表或其他数据结构。使用回调、收益和/or其他编码实践来限制结构在内存中的花费时间。
另外,我建议将您的代码提交给代码评审SE,我认为它们可能也会有所帮助。
发布于 2017-12-24 17:34:34
简单地说,你不能手动管理内存。但是,您的问题应该是,如何减少Python使用的内存量?
首先,要知道你的程序分配的内存量和它的使用量是有区别的。
第二,避免分配不需要的内存。每个切片操作都会创建一个新的str对象。相反,使用startswith方法:
if not a:
if a.startswith('/http'):
a = a[1:]
if a.startswith('//http'):
a = a[2:]
if a[.startswith("https://www." + url1):
cursor.execute("insert ignore into urls(urls,status,status_code) values(%s,'pending',%s)",
[a, r.status_code])等。
https://stackoverflow.com/questions/47962083
复制相似问题