Очистка электронной почты с веб-сайтов - PullRequest
0 голосов
/ 28 мая 2020
• 1000 содержать адреса электронной почты. Затем я хочу сохранить URL-адреса и адреса электронной почты в файле csv.

Например, если я перешел на 10torr.com, программа должна найти каждый из сайтов в основном URL-адресе (ie : 10torr.com/about) и извлекайте все электронные письма.

Ниже приведен список из 5 примеров веб-сайтов, которые в настоящее время находятся в формате фрейма данных при запуске моего кода. Они сохраняются под переменной small_site.

Полезный ответ будет включать использование указанной ниже пользовательской функции под названием get_info(). Жесткое кодирование веб-сайтов в самом Spider не является возможным вариантом, так как это будет использоваться многими другими людьми с разной длиной списка веб-сайтов.

    Website
    http://10torr.com/
    https://www.10000drops.com/
    https://www.11wells.com/
    https://117westspirits.com/
    https://www.onpointdistillery.com/

Ниже приведен код, который я использую. Паук, кажется, запускается, но в моем csv файле нет вывода.


import os
import pandas as pd
import re
import scrapy
from scrapy.crawler import CrawlerProcess
from scrapy.linkextractors.lxmlhtml import LxmlLinkExtractor

small_site = site.head()


#%% Start Spider
class MailSpider(scrapy.Spider):

    name = 'email'

    def parse(self, response):

        links = LxmlLinkExtractor(allow=()).extract_links(response)
        links = [str(link.url) for link in links]
        links.append(str(response.url))

        for link in links:
            yield scrapy.Request(url=link, callback=self.parse_link) 

    def parse_link(self, response):

        for word in self.reject:
            if word in str(response.url):
                return

        html_text = str(response.text)
        mail_list = re.findall('\w+@\w+\.{1}\w+', html_text)

        dic = {'email': mail_list, 'link': str(response.url)}
        df = pd.DataFrame(dic)

        df.to_csv(self.path, mode='a', header=False)
        df.to_csv(self.path, mode='a', header=False)


#%% Preps a CSV File
def ask_user(question):
    response = input(question + ' y/n' + '\n')
    if response == 'y':
        return True
    else:
        return False
def create_file(path):
    response = False
    if os.path.exists(path):
        response = ask_user('File already exists, replace?')
        if response == False: return 

    with open(path, 'wb') as file: 
        file.close()


#%% Defines function that will extract emails and enter it into CSV
def get_info(url_list, path, reject=[]):

    create_file(path)
    df = pd.DataFrame(columns=['email', 'link'], index=[0])
    df.to_csv(path, mode='w', header=True)


    print('Collecting Google urls...')
    google_urls = url_list


    print('Searching for emails...')
    process = CrawlerProcess({'USER_AGENT': 'Mozilla/5.0'})
    process.start() 

    for i in small_site.Website.iteritems():
        print('Searching for emails...')
        process.crawl(MailSpider, start_urls=google_urls, path=path, reject=reject)
        ##process.start()

        print('Cleaning emails...')
        df = pd.read_csv(path, index_col=0)
        df.columns = ['email', 'link']
        df = df.drop_duplicates(subset='email')
        df = df.reset_index(drop=True)
        df.to_csv(path, mode='w', header=True)


    return df


url_list = small_site
path = 'email.csv'

df = get_info(url_list, path)

Я не уверен, где я ошибаюсь, поскольку я не получаю сообщений об ошибках. Если вам нужна дополнительная информация, просто спросите. Я пытаюсь получить это уже почти месяц, и мне кажется, что сейчас я просто бьюсь головой об стену.

Большая часть этого кода была найдена в статье Веб-скрапинг для извлечения контактной информации - Часть 1: Списки рассылки через несколько недель. Однако мне не удалось расширить его для своих нужд. При включении функции поиска в Google для получения базовых URL-адресов проблем не возникло.

Заранее благодарим вас за любую помощь, которую вы можете оказать.

Ответы [ 2 ]

0 голосов
/ 04 сентября 2020

Это заняло некоторое время, но, наконец, я получил ответ. Вот как пришел окончательный ответ. Это будет работать с изменяющимся списком, как и в исходном вопросе.

Изменение оказалось очень незначительным. Мне нужно было добавить следующую пользовательскую функцию.

def get_urls(io, sheet_name):
    data = pd.read_excel(io, sheet_name)
    urls = data['Website'].to_list()
    return urls

Оттуда это было простое изменение get_info() пользовательской функции. Нам нужно было установить google_urls в этой функции на нашу get_urls функцию и передать список. Полный код этой функции приведен ниже.

def get_info(io, sheet_name, path, reject=[]):
    
    create_file(path)
    df = pd.DataFrame(columns=['email', 'link'], index=[0])
    df.to_csv(path, mode='w', header=True)
    
    print('Collecting Google urls...')
    google_urls = get_urls(io, sheet_name)
    
    print('Searching for emails...')
    process = CrawlerProcess({'USER_AGENT': 'Mozilla/5.0'})
    process.crawl(MailSpider, start_urls=google_urls, path=path, reject=reject)
    process.start()
    
    print('Cleaning emails...')
    df = pd.read_csv(path, index_col=0)
    df.columns = ['email', 'link']
    df = df.drop_duplicates(subset='email')
    df = df.reset_index(drop=True)
    df.to_csv(path, mode='w', header=True)
    
    return df

Никаких других изменений для запуска этой функции не требовалось. Надеюсь, это поможет.

0 голосов
/ 29 мая 2020

Я изменил некоторые сценарии, запустил следующий сценарий через Shell, и он работает. Может быть, это послужит вам отправной точкой.

Я советую вам использовать оболочку, поскольку она всегда выдает ошибки и другие сообщения во время процесса очистки


class MailSpider(scrapy.Spider):

    name = 'email'
    start_urls = [
        'http://10torr.com/',
        'https://www.10000drops.com/',
        'https://www.11wells.com/',
        'https://117westspirits.com/',
        'https://www.onpointdistillery.com/',
    ]

    def parse(self, response):
        self.log('A response from %s just arrived!' % response.url)
        links = LxmlLinkExtractor(allow=()).extract_links(response)
        links = [str(link.url) for link in links]
        links.append(str(response.url))

        for link in links:
            yield scrapy.Request(url=link, callback=self.parse_link) 

    def parse_link(self, response):

        html_text = str(response.text)
        mail_list = re.findall('\w+@\w+\.{1}\w+', html_text)

        dic = {'email': mail_list, 'link': str(response.url)}

        for key in dic.keys():
            yield {
                'email' : dic['email'],
                'link': dic['link'],
            }

Это дает следующее вывод при сканировании через оболочку Anaconda scrapy crawl email -o test.jl

{"email": ["info@ndiscovered.com"], "link": "https://117westspirits.com/"}
{"email": ["8b4e078a51d04e0e9efdf470027f0ec1@sentry.wixpress", "bundle@3.2", "fetch@3.0", "bolt@2.3", "5oclock@11wells.com", "5oclock@11wells.com", "5oclock@11wells.com"], "link": "https://www.11wells.com"}
{"email": ["info@ndiscovered.com"], "link": "https://117westspirits.com/shop?olsPage=search&keywords="}
{"email": ["info@ndiscovered.com"], "link": "https://117westspirits.com/shop?olsPage=search&keywords="}
{"email": ["info@ndiscovered.com"], "link": "https://117westspirits.com/shop"}
{"email": ["info@ndiscovered.com"], "link": "https://117westspirits.com/shop?olsPage=cart"}
{"email": ["info@ndiscovered.com"], "link": "https://117westspirits.com/home"}
{"email": ["8b4e078a51d04e0e9efdf470027f0ec1@sentry.wixpress", "bundle@3.2", "fetch@3.0", "bolt@2.3", "5oclock@11wells.com", "5oclock@11wells.com", "5oclock@11wells.com"], "link": "https://www.11wells.com"}
{"email": ["info@ndiscovered.com"], "link": "https://117westspirits.com/home"}
{"email": ["info@ndiscovered.com"], "link": "https://117westspirits.com/117%C2%B0-west-spirits-1"}
...
...
...

См. Scrapy docs для получения дополнительной информации

...