Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
crawlersNoticias
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
4
Issues
4
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
m3
crawlersNoticias
Commits
c908a556
Commit
c908a556
authored
Oct 12, 2018
by
Renán Sosa Guillen
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
laJornadaMaya update
parent
566f8f06
Changes
6
Show whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
400 additions
and
219 deletions
+400
-219
items.py
descarga_hacia_atras/laJornadaMaya/laJornadaMaya/items.py
+9
-3
middlewares.py
...ga_hacia_atras/laJornadaMaya/laJornadaMaya/middlewares.py
+52
-5
pipelines.py
...arga_hacia_atras/laJornadaMaya/laJornadaMaya/pipelines.py
+66
-2
settings.py
descarga_hacia_atras/laJornadaMaya/laJornadaMaya/settings.py
+17
-17
noticias.py
...cia_atras/laJornadaMaya/laJornadaMaya/spiders/noticias.py
+255
-191
scrapy.cfg
descarga_hacia_atras/laJornadaMaya/scrapy.cfg
+1
-1
No files found.
descarga_hacia_atras/laJornadaMaya/laJornadaMaya/items.py
View file @
c908a556
...
@@ -3,12 +3,18 @@
...
@@ -3,12 +3,18 @@
# Define here the models for your scraped items
# Define here the models for your scraped items
#
#
# See documentation in:
# See documentation in:
# http://doc.scrapy.org/en/latest/topics/items.html
# http
s
://doc.scrapy.org/en/latest/topics/items.html
import
scrapy
import
scrapy
class
Lajornadamaya
Item
(
scrapy
.
Item
):
class
Noticias
Item
(
scrapy
.
Item
):
# define the fields for your item here like:
# define the fields for your item here like:
# name = scrapy.Field()
# name = scrapy.Field()
pass
title
=
scrapy
.
Field
()
text
=
scrapy
.
Field
()
date
=
scrapy
.
Field
()
location
=
scrapy
.
Field
()
author
=
scrapy
.
Field
()
topic
=
scrapy
.
Field
()
url
=
scrapy
.
Field
()
descarga_hacia_atras/laJornadaMaya/laJornadaMaya/middlewares.py
View file @
c908a556
...
@@ -3,7 +3,7 @@
...
@@ -3,7 +3,7 @@
# Define here the models for your spider middleware
# Define here the models for your spider middleware
#
#
# See documentation in:
# See documentation in:
# http://doc.scrapy.org/en/latest/topics/spider-middleware.html
# http
s
://doc.scrapy.org/en/latest/topics/spider-middleware.html
from
scrapy
import
signals
from
scrapy
import
signals
...
@@ -20,14 +20,14 @@ class LajornadamayaSpiderMiddleware(object):
...
@@ -20,14 +20,14 @@ class LajornadamayaSpiderMiddleware(object):
crawler
.
signals
.
connect
(
s
.
spider_opened
,
signal
=
signals
.
spider_opened
)
crawler
.
signals
.
connect
(
s
.
spider_opened
,
signal
=
signals
.
spider_opened
)
return
s
return
s
def
process_spider_input
(
response
,
spider
):
def
process_spider_input
(
self
,
response
,
spider
):
# Called for each response that goes through the spider
# Called for each response that goes through the spider
# middleware and into the spider.
# middleware and into the spider.
# Should return None or raise an exception.
# Should return None or raise an exception.
return
None
return
None
def
process_spider_output
(
response
,
result
,
spider
):
def
process_spider_output
(
self
,
response
,
result
,
spider
):
# Called with the results returned from the Spider, after
# Called with the results returned from the Spider, after
# it has processed the response.
# it has processed the response.
...
@@ -35,7 +35,7 @@ class LajornadamayaSpiderMiddleware(object):
...
@@ -35,7 +35,7 @@ class LajornadamayaSpiderMiddleware(object):
for
i
in
result
:
for
i
in
result
:
yield
i
yield
i
def
process_spider_exception
(
response
,
exception
,
spider
):
def
process_spider_exception
(
self
,
response
,
exception
,
spider
):
# Called when a spider or process_spider_input() method
# Called when a spider or process_spider_input() method
# (from other spider middleware) raises an exception.
# (from other spider middleware) raises an exception.
...
@@ -43,7 +43,7 @@ class LajornadamayaSpiderMiddleware(object):
...
@@ -43,7 +43,7 @@ class LajornadamayaSpiderMiddleware(object):
# or Item objects.
# or Item objects.
pass
pass
def
process_start_requests
(
start_requests
,
spider
):
def
process_start_requests
(
s
elf
,
s
tart_requests
,
spider
):
# Called with the start requests of the spider, and works
# Called with the start requests of the spider, and works
# similarly to the process_spider_output() method, except
# similarly to the process_spider_output() method, except
# that it doesn’t have a response associated.
# that it doesn’t have a response associated.
...
@@ -54,3 +54,50 @@ class LajornadamayaSpiderMiddleware(object):
...
@@ -54,3 +54,50 @@ class LajornadamayaSpiderMiddleware(object):
def
spider_opened
(
self
,
spider
):
def
spider_opened
(
self
,
spider
):
spider
.
logger
.
info
(
'Spider opened:
%
s'
%
spider
.
name
)
spider
.
logger
.
info
(
'Spider opened:
%
s'
%
spider
.
name
)
class
LajornadamayaDownloaderMiddleware
(
object
):
# Not all methods need to be defined. If a method is not defined,
# scrapy acts as if the downloader middleware does not modify the
# passed objects.
@
classmethod
def
from_crawler
(
cls
,
crawler
):
# This method is used by Scrapy to create your spiders.
s
=
cls
()
crawler
.
signals
.
connect
(
s
.
spider_opened
,
signal
=
signals
.
spider_opened
)
return
s
def
process_request
(
self
,
request
,
spider
):
# Called for each request that goes through the downloader
# middleware.
# Must either:
# - return None: continue processing this request
# - or return a Response object
# - or return a Request object
# - or raise IgnoreRequest: process_exception() methods of
# installed downloader middleware will be called
return
None
def
process_response
(
self
,
request
,
response
,
spider
):
# Called with the response returned from the downloader.
# Must either;
# - return a Response object
# - return a Request object
# - or raise IgnoreRequest
return
response
def
process_exception
(
self
,
request
,
exception
,
spider
):
# Called when a download handler or a process_request()
# (from other downloader middleware) raises an exception.
# Must either:
# - return None: continue processing this exception
# - return a Response object: stops process_exception() chain
# - return a Request object: stops process_exception() chain
pass
def
spider_opened
(
self
,
spider
):
spider
.
logger
.
info
(
'Spider opened:
%
s'
%
spider
.
name
)
descarga_hacia_atras/laJornadaMaya/laJornadaMaya/pipelines.py
View file @
c908a556
...
@@ -3,9 +3,73 @@
...
@@ -3,9 +3,73 @@
# Define your item pipelines here
# Define your item pipelines here
#
#
# Don't forget to add your pipeline to the ITEM_PIPELINES setting
# Don't forget to add your pipeline to the ITEM_PIPELINES setting
# See: http://doc.scrapy.org/en/latest/topics/item-pipeline.html
# See: http
s
://doc.scrapy.org/en/latest/topics/item-pipeline.html
import
json
from
collections
import
OrderedDict
class
JsonWriterPipeline
(
object
):
def
__init__
(
self
,
filename
):
self
.
filename
=
filename
@
classmethod
def
from_crawler
(
cls
,
crawler
):
# Here you get whatever value was passed through the "filename" command line parameter
settings
=
crawler
.
settings
filename
=
settings
.
get
(
'filename'
)
# Instantiate the pipeline with the file name
return
cls
(
filename
)
def
open_spider
(
self
,
spider
):
self
.
counter
=
0
self
.
file
=
open
(
self
.
filename
,
'w'
)
self
.
file
.
write
(
"["
)
def
close_spider
(
self
,
spider
):
self
.
file
.
write
(
"]"
)
self
.
file
.
close
()
class
LajornadamayaPipeline
(
object
):
def
process_item
(
self
,
item
,
spider
):
def
process_item
(
self
,
item
,
spider
):
# print("this is my item", item)
row
=
[]
try
:
row
.
append
((
"date"
,
item
[
'date'
]))
except
:
pass
try
:
row
.
append
((
"topic"
,
item
[
'topic'
]))
except
:
pass
try
:
row
.
append
((
"title"
,
item
[
'title'
]))
except
:
pass
try
:
row
.
append
((
"author"
,
item
[
'author'
]))
except
:
pass
try
:
row
.
append
((
"location"
,
item
[
'location'
]))
except
:
pass
try
:
row
.
append
((
"text"
,
item
[
'text'
]))
except
:
pass
try
:
row
.
append
((
"url"
,
item
[
'url'
]))
except
:
pass
line
=
OrderedDict
(
row
)
self
.
counter
+=
1
if
self
.
counter
==
1
:
self
.
file
.
write
(
json
.
dumps
(
line
))
elif
self
.
counter
>
1
:
self
.
file
.
write
(
",
\n
"
+
json
.
dumps
(
line
))
return
item
return
item
descarga_hacia_atras/laJornadaMaya/laJornadaMaya/settings.py
View file @
c908a556
...
@@ -5,9 +5,9 @@
...
@@ -5,9 +5,9 @@
# For simplicity, this file contains only settings considered important or
# For simplicity, this file contains only settings considered important or
# commonly used. You can find more settings consulting the documentation:
# commonly used. You can find more settings consulting the documentation:
#
#
# http://doc.scrapy.org/en/latest/topics/settings.html
# http
s
://doc.scrapy.org/en/latest/topics/settings.html
# http
://scrapy.readthedocs
.org/en/latest/topics/downloader-middleware.html
# http
s://doc.scrapy
.org/en/latest/topics/downloader-middleware.html
# http
://scrapy.readthedocs
.org/en/latest/topics/spider-middleware.html
# http
s://doc.scrapy
.org/en/latest/topics/spider-middleware.html
BOT_NAME
=
'laJornadaMaya'
BOT_NAME
=
'laJornadaMaya'
...
@@ -19,21 +19,21 @@ NEWSPIDER_MODULE = 'laJornadaMaya.spiders'
...
@@ -19,21 +19,21 @@ NEWSPIDER_MODULE = 'laJornadaMaya.spiders'
#USER_AGENT = 'laJornadaMaya (+http://www.yourdomain.com)'
#USER_AGENT = 'laJornadaMaya (+http://www.yourdomain.com)'
# Obey robots.txt rules
# Obey robots.txt rules
ROBOTSTXT_OBEY
=
True
#
ROBOTSTXT_OBEY = True
# Configure maximum concurrent requests performed by Scrapy (default: 16)
# Configure maximum concurrent requests performed by Scrapy (default: 16)
#CONCURRENT_REQUESTS = 32
#CONCURRENT_REQUESTS = 32
# Configure a delay for requests for the same website (default: 0)
# Configure a delay for requests for the same website (default: 0)
# See http
://scrapy.readthedocs
.org/en/latest/topics/settings.html#download-delay
# See http
s://doc.scrapy
.org/en/latest/topics/settings.html#download-delay
# See also autothrottle settings and docs
# See also autothrottle settings and docs
#DOWNLOAD_DELAY = 3
DOWNLOAD_DELAY
=
0.5
# The download delay setting will honor only one of:
# The download delay setting will honor only one of:
#CONCURRENT_REQUESTS_PER_DOMAIN = 16
#CONCURRENT_REQUESTS_PER_DOMAIN = 16
#CONCURRENT_REQUESTS_PER_IP = 16
#CONCURRENT_REQUESTS_PER_IP = 16
# Disable cookies (enabled by default)
# Disable cookies (enabled by default)
#
COOKIES_ENABLED = False
COOKIES_ENABLED
=
False
# Disable Telnet Console (enabled by default)
# Disable Telnet Console (enabled by default)
#TELNETCONSOLE_ENABLED = False
#TELNETCONSOLE_ENABLED = False
...
@@ -45,31 +45,31 @@ ROBOTSTXT_OBEY = True
...
@@ -45,31 +45,31 @@ ROBOTSTXT_OBEY = True
#}
#}
# Enable or disable spider middlewares
# Enable or disable spider middlewares
# See http
://scrapy.readthedocs
.org/en/latest/topics/spider-middleware.html
# See http
s://doc.scrapy
.org/en/latest/topics/spider-middleware.html
#SPIDER_MIDDLEWARES = {
#SPIDER_MIDDLEWARES = {
# 'laJornadaMaya.middlewares.LajornadamayaSpiderMiddleware': 543,
# 'laJornadaMaya.middlewares.LajornadamayaSpiderMiddleware': 543,
#}
#}
# Enable or disable downloader middlewares
# Enable or disable downloader middlewares
# See http
://scrapy.readthedocs
.org/en/latest/topics/downloader-middleware.html
# See http
s://doc.scrapy
.org/en/latest/topics/downloader-middleware.html
#DOWNLOADER_MIDDLEWARES = {
#DOWNLOADER_MIDDLEWARES = {
# 'laJornadaMaya.middlewares.
MyCustom
DownloaderMiddleware': 543,
# 'laJornadaMaya.middlewares.
Lajornadamaya
DownloaderMiddleware': 543,
#}
#}
# Enable or disable extensions
# Enable or disable extensions
# See http
://scrapy.readthedocs
.org/en/latest/topics/extensions.html
# See http
s://doc.scrapy
.org/en/latest/topics/extensions.html
#EXTENSIONS = {
#EXTENSIONS = {
# 'scrapy.extensions.telnet.TelnetConsole': None,
# 'scrapy.extensions.telnet.TelnetConsole': None,
#}
#}
# Configure item pipelines
# Configure item pipelines
# See http
://scrapy.readthedocs
.org/en/latest/topics/item-pipeline.html
# See http
s://doc.scrapy
.org/en/latest/topics/item-pipeline.html
#
ITEM_PIPELINES = {
ITEM_PIPELINES
=
{
# 'laJornadaMaya.pipelines.Lajornadamaya
Pipeline': 300,
'laJornadaMaya.pipelines.JsonWriter
Pipeline'
:
300
,
#
}
}
# Enable and configure the AutoThrottle extension (disabled by default)
# Enable and configure the AutoThrottle extension (disabled by default)
# See http://doc.scrapy.org/en/latest/topics/autothrottle.html
# See http
s
://doc.scrapy.org/en/latest/topics/autothrottle.html
#AUTOTHROTTLE_ENABLED = True
#AUTOTHROTTLE_ENABLED = True
# The initial download delay
# The initial download delay
#AUTOTHROTTLE_START_DELAY = 5
#AUTOTHROTTLE_START_DELAY = 5
...
@@ -82,7 +82,7 @@ ROBOTSTXT_OBEY = True
...
@@ -82,7 +82,7 @@ ROBOTSTXT_OBEY = True
#AUTOTHROTTLE_DEBUG = False
#AUTOTHROTTLE_DEBUG = False
# Enable and configure HTTP caching (disabled by default)
# Enable and configure HTTP caching (disabled by default)
# See http
://scrapy.readthedocs
.org/en/latest/topics/downloader-middleware.html#httpcache-middleware-settings
# See http
s://doc.scrapy
.org/en/latest/topics/downloader-middleware.html#httpcache-middleware-settings
#HTTPCACHE_ENABLED = True
#HTTPCACHE_ENABLED = True
#HTTPCACHE_EXPIRATION_SECS = 0
#HTTPCACHE_EXPIRATION_SECS = 0
#HTTPCACHE_DIR = 'httpcache'
#HTTPCACHE_DIR = 'httpcache'
...
...
descarga_hacia_atras/laJornadaMaya/laJornadaMaya/spiders/noticias.py
View file @
c908a556
import
scrapy
,
json
,
re
# -*- coding: utf-8 -*-
from
datetime
import
datetime
,
date
,
timedelta
,
tzinfo
"""
"""
Esta version descarga ingresando una fecha.
MEDIA:
USO:
La Jornada Maya, Yucatán
scrapy crawl noticias -t json --nolog -o noticias.json -a year=2017 -a month=3 -a day=22
USAGE:
$ cd laJornadaMaya/
------------------------------------------------------------------------------------------------------------
## Get all the news from the most current to the oldest. It's necessary to use the parse_date_files.py file
for the news contained in noticias.json being splitted into files by date. ##
No es recomendable para fechas de mas de un mes de antiguas.
$ scrapy crawl noticias --nolog -s filename=noticias.json
------------------------------------------------------------------------------------------------------------
## Get all the news from the most current to a specific date. ##
$ scrapy crawl noticias --nolog -s filename=2018-08-10.json -a year=2018 -a month=8 -a day=10
"""
"""
import
scrapy
,
re
,
json
from
datetime
import
datetime
,
date
from
laJornadaMaya.items
import
NoticiasItem
TAG_RE
=
re
.
compile
(
r'<[^>]+>'
)
TAG_RE
=
re
.
compile
(
r'<[^>]+>'
)
def
remove_tags
(
text
):
def
remove_tags
(
text
):
return
TAG_RE
.
sub
(
''
,
text
)
return
TAG_RE
.
sub
(
''
,
text
)
class
UTC
(
tzinfo
):
"""clase para el 'time zone' (zona horaria)"""
def
utcoffset
(
self
,
dt
):
# zona horaria para yucatan (centro de mexico): utc-6
return
timedelta
(
hours
=-
6
)
def
tzname
(
self
,
dt
):
class
ImportantFlowData
(
scrapy
.
Item
):
# nombre de la zona horaria
"""
return
'UTC-6'
Useful data for the flow of the implementation
"""
to_next_page
=
scrapy
.
Field
()
is_last_link
=
scrapy
.
Field
()
return_url
=
scrapy
.
Field
()
current_page
=
scrapy
.
Field
()
news_section
=
scrapy
.
Field
()
class
NoticiasItem
(
scrapy
.
Item
):
title
=
scrapy
.
Field
()
text
=
scrapy
.
Field
()
date
=
scrapy
.
Field
()
location
=
scrapy
.
Field
()
author
=
scrapy
.
Field
()
topic
=
scrapy
.
Field
()
url
=
scrapy
.
Field
()
class
QuotesSpider
(
scrapy
.
Spider
):
class
QuotesSpider
(
scrapy
.
Spider
):
"""
Basic Scrapy Spider class
"""
name
=
"noticias"
name
=
"noticias"
def
start_requests
(
self
):
def
start_requests
(
self
):
# self.found = False
year
=
getattr
(
self
,
"year"
,
None
)
# self.flag = False
month
=
getattr
(
self
,
"month"
,
None
)
self
.
tz
=
UTC
()
day
=
getattr
(
self
,
"day"
,
None
)
self
.
year
=
getattr
(
self
,
'year'
,
None
)
self
.
month
=
getattr
(
self
,
'month'
,
None
)
self
.
base_url
=
"https://www.lajornadamaya.mx/"
self
.
day
=
getattr
(
self
,
'day'
,
None
)
section_list
=
[
"yucatan"
,
"quintana-roo"
,
"campeche"
,
"nacional"
,
"internacional"
,
"deportes"
,
"opinion"
]
self
.
req_date
=
date
(
int
(
self
.
year
),
int
(
self
.
month
),
int
(
self
.
day
))
self
.
date_format
=
"
%
Y-
%
m-
%
d"
self
.
baseURL
=
'https://www.lajornadamaya.mx'
section_list
=
[
'yucatan'
,
'quintana-roo'
,
'campeche'
,
'deportes'
,
'nacional'
,
'internacional'
,
'opinion'
]
# section_list = ['deportes']
for
section
in
section_list
:
self
.
section
=
section
for
count
in
range
(
0
,
2
):
if
(
count
==
0
):
yield
scrapy
.
Request
(
url
=
self
.
baseURL
+
'/'
+
section
,
callback
=
self
.
parse_2
)
elif
(
count
==
1
):
# self.section = section
self
.
page
=
0
self
.
flag
=
False
self
.
found
=
False
page
=
-
1
if
not
(
section
==
'opinion'
):
while
True
:
if
(
self
.
flag
):
self
.
flag
=
False
break
page
+=
1
yield
scrapy
.
Request
(
url
=
self
.
baseURL
+
'/'
+
section
+
'?p='
+
str
(
page
),
callback
=
self
.
parse
)
if
(
self
.
found
):
if
year
is
not
None
and
month
is
not
None
and
day
is
not
None
:
self
.
found
=
False
self
.
stop_date
=
date
(
int
(
year
),
int
(
month
),
int
(
day
))
self
.
page
-=
1
if
(
self
.
page
>
0
):
self
.
page
-=
1
for
pag
in
range
(
self
.
page
,
self
.
page
+
6
):
for
s
in
section_list
:
yield
scrapy
.
Request
(
url
=
self
.
baseURL
+
'/'
+
section
+
'?p='
+
str
(
pag
),
callback
=
self
.
parse_page
,
dont_filter
=
True
)
flow_info
=
ImportantFlowData
()
flow_info
[
'to_next_page'
]
=
False
flow_info
[
'news_section'
]
=
s
request
=
scrapy
.
Request
(
url
=
self
.
base_url
+
s
,
callback
=
self
.
parse_with_stop_date_1
)
request
.
meta
[
'item'
]
=
flow_info
yield
request
else
:
else
:
yield
scrapy
.
Request
(
url
=
self
.
baseURL
+
'/notas?opinion'
,
callback
=
self
.
parse_page
)
if
year
is
None
and
month
is
None
and
day
is
None
:
self
.
stop_date
=
None
for
s
in
section_list
:
flow_info
=
ImportantFlowData
()
flow_info
[
'news_section'
]
=
s
request
=
scrapy
.
Request
(
url
=
self
.
base_url
+
s
,
callback
=
self
.
parse
)
request
.
meta
[
'item'
]
=
flow_info
yield
request
else
:
print
"Unable to execute this crawler with current given parameters."
print
"Enter all parameters: year, month and day, or none of them."
def
parse_2
(
self
,
response
):
# para las primeras noticias
path_list
=
[
'//h1[@class="title"]/a/@href'
,
'//h2[@class="title"]/a/@href'
]
link_list
=
[]
def
parse
(
self
,
response
):
for
path
in
path_list
:
flow_info
=
response
.
meta
[
'item'
]
link_list
+=
response
.
xpath
(
path
)
.
extract
()
s
=
flow_info
[
'news_section'
]
link_list
=
response
.
css
(
'div.slide'
)
.
css
(
'h1.title > a::attr(href)'
)
.
extract
()
link_list
.
extend
(
response
.
css
(
'div.moreArticles'
)
.
css
(
'h2.title > a::attr(href)'
)
.
extract
())
for
link
in
link_list
:
for
link
in
link_list
:
if
(
link
[:
link
.
rfind
(
'/'
)]
==
self
.
year
+
'-'
+
self
.
month
.
zfill
(
2
)
+
'-'
+
self
.
day
.
zfill
(
2
)
):
item_info
=
ImportantFlowData
()
item
=
NoticiasItem
()
item_info
[
'news_section'
]
=
s
d
=
link
[:
link
.
rfind
(
'/'
)]
reqst
=
scrapy
.
Request
(
url
=
self
.
base_url
+
link
,
callback
=
self
.
parse_item
)
if
len
(
d
)
==
10
:
reqst
.
meta
[
'item'
]
=
item_info
d
=
map
(
int
,
d
.
split
(
'-'
))
yield
reqst
d
=
datetime
(
d
[
0
],
d
[
1
],
d
[
2
],
tzinfo
=
self
.
tz
)
.
isoformat
(
'T'
)
elif
len
(
d
)
==
19
:
p
=
0
d
,
t
=
d
.
split
(
' '
)
flow_info
=
ImportantFlowData
()
d
=
map
(
int
,
d
.
split
(
'-'
))
flow_info
[
'current_page'
]
=
p
t
=
map
(
int
,
t
.
split
(
':'
))
flow_info
[
'news_section'
]
=
s
d
=
datetime
(
d
[
0
],
d
[
1
],
d
[
2
],
t
[
0
],
t
[
1
],
t
[
2
],
tzinfo
=
self
.
tz
)
.
isoformat
(
'T'
)
item
[
'date'
]
=
d
request
=
scrapy
.
Request
(
url
=
self
.
base_url
+
s
+
"?p="
+
str
(
p
),
callback
=
self
.
parse_2
)
request
.
meta
[
'item'
]
=
flow_info
yield
request
def
parse_2
(
self
,
response
):
flow_info
=
response
.
meta
[
'item'
]
p
=
flow_info
[
'current_page'
]
s
=
flow_info
[
'news_section'
]
news_list
=
json
.
loads
(
response
.
body
)
if
len
(
news_list
)
>
0
:
url
=
self
.
base_url
[:
self
.
base_url
.
rfind
(
"/"
)]
item
[
'topic'
]
=
response
.
url
[
response
.
url
.
rfind
(
'/'
)
+
1
:]
.
title
()
for
news
in
news_list
:
# yield scrapy.Request(url=self.baseURL+'/'+link, callback=self.parse_item_2)
item_info
=
ImportantFlowData
()
request
=
scrapy
.
Request
(
url
=
self
.
baseURL
+
'/'
+
link
,
callback
=
self
.
parse_item_2
)
item_info
[
'news_section'
]
=
s
request
.
meta
[
'item'
]
=
item
reqst
=
scrapy
.
Request
(
url
=
url
+
news
[
'url'
],
callback
=
self
.
parse_item
)
reqst
.
meta
[
'item'
]
=
item_info
yield
reqst
p
+=
1
flow_info
[
'current_page'
]
=
p
request
=
scrapy
.
Request
(
url
=
self
.
base_url
+
s
+
"?p="
+
str
(
p
),
callback
=
self
.
parse_2
)
request
.
meta
[
'item'
]
=
flow_info
yield
request
yield
request
def
parse
(
self
,
response
):
# para los json
json_response
=
json
.
loads
(
response
.
text
)
if
not
(
response
.
url
[
response
.
url
.
rfind
(
'/'
)
+
1
:]
==
'notas?opinion'
):
def
parse_with_stop_date_1
(
self
,
response
):
json_list
=
json_response
flow_info
=
response
.
meta
[
'item'
]
s
=
flow_info
[
'news_section'
]
if
not
flow_info
[
'to_next_page'
]:
link_list
=
response
.
css
(
'div.slide'
)
.
css
(
'h1.title > a::attr(href)'
)
.
extract
()
link_list
.
extend
(
response
.
css
(
'div.moreArticles'
)
.
css
(
'h2.title > a::attr(href)'
)
.
extract
())
for
link
in
link_list
:
item_info
=
ImportantFlowData
()
item_info
[
'news_section'
]
=
s
item_info
[
'return_url'
]
=
response
.
url
if
link_list
.
index
(
link
)
==
link_list
.
index
(
link_list
[
-
1
]):
item_info
[
'is_last_link'
]
=
True
else
:
else
:
json_list
=
json_response
[
'articles'
]
item_info
[
'is_last_link'
]
=
False
for
line
in
json_list
:
request
=
scrapy
.
Request
(
url
=
self
.
base_url
+
link
,
callback
=
self
.
parse_item_with_stop_date
)
this_date
=
datetime
.
strptime
(
line
[
'publishDate'
][:
line
[
'publishDate'
]
.
rfind
(
' '
)],
self
.
date_format
)
request
.
meta
[
'item'
]
=
item_info
this_date
=
this_date
.
date
()
yield
request
if
(
this_date
==
self
.
req_date
):
else
:
self
.
page
=
int
(
response
.
url
[
response
.
url
.
rfind
(
'='
)
+
1
:])
flow_info
=
ImportantFlowData
()
self
.
found
=
True
p
=
0
self
.
flag
=
True
flow_info
[
'current_page'
]
=
p
break
flow_info
[
'news_section'
]
=
s
elif
(
this_date
<
self
.
req_date
):
self
.
flag
=
True
break
request
=
scrapy
.
Request
(
url
=
self
.
base_url
+
s
+
"?p="
+
str
(
p
),
callback
=
self
.
parse_with_stop_date_2
)
request
.
meta
[
'item'
]
=
flow_info
yield
request
def
parse_item_2
(
self
,
response
):
# para las primeras noticias
item
=
response
.
meta
[
'item'
]
# item = NoticiasItem()
text
=
''
# item['date'] = response.url[:response.url.rfind('/')][response.url[:response.url.rfind('/')].rfind('/')+1:]
# item['topic'] = self.section.title()
item
[
'title'
]
=
response
.
xpath
(
'//article/h1/text()'
)
.
extract_first
()
for
paragraph
in
response
.
xpath
(
'//*[@class="txt"]'
)
.
extract
():
text
+=
remove_tags
(
paragraph
)
+
'
\n
'
item
[
'text'
]
=
text
item
[
'url'
]
=
response
.
url
print
item
[
'title'
]
yield
item
def
parse_page
(
self
,
response
):
# para los json
def
parse_with_stop_date_2
(
self
,
response
):
json_response
=
json
.
loads
(
response
.
text
)
flow_info
=
response
.
meta
[
'item'
]
p
=
flow_info
[
'current_page'
]
s
=
flow_info
[
'news_section'
]
news_list
=
json
.
loads
(
response
.
body
)
if
len
(
news_list
)
>
0
:
url
=
self
.
base_url
[:
self
.
base_url
.
rfind
(
"/"
)]
for
news
in
news_list
:
news_date
=
datetime
.
strptime
(
news
[
'publishDate'
],
'
%
Y-
%
m-
%
d
%
H:
%
M:
%
S'
)
.
date
()
if
news_date
>=
self
.
stop_date
:
item_info
=
ImportantFlowData
()
item_info
[
'news_section'
]
=
s
reqst
=
scrapy
.
Request
(
url
=
url
+
news
[
'url'
],
callback
=
self
.
parse_item
)
reqst
.
meta
[
'item'
]
=
item_info
yield
reqst
if
news_list
.
index
(
news
)
==
news_list
.
index
(
news_list
[
-
1
]):
p
+=
1
flow_info
=
ImportantFlowData
()
flow_info
[
'current_page'
]
=
p
flow_info
[
'news_section'
]
=
s
request
=
scrapy
.
Request
(
url
=
self
.
base_url
+
s
+
"?p="
+
str
(
p
),
callback
=
self
.
parse_with_stop_date_2
)
request
.
meta
[
'item'
]
=
flow_info
yield
request
if
not
(
response
.
url
[
response
.
url
.
rfind
(
'/'
)
+
1
:]
==
'notas?opinion'
):
topic
=
response
.
url
[
response
.
url
.
rfind
(
'/'
)
+
1
:
response
.
url
.
rfind
(
'='
)
-
2
]
.
title
()
json_list
=
json_response
else
:
else
:
json_list
=
json_response
[
'articles'
]
break
topic
=
'Opinion'
for
line
in
json_list
:
this_date
=
datetime
.
strptime
(
line
[
'publishDate'
][:
line
[
'publishDate'
]
.
rfind
(
' '
)],
self
.
date_format
)
this_date
=
this_date
.
date
()
if
(
this_date
==
self
.
req_date
):
def
parse_item
(
self
,
response
):
flow_info
=
response
.
meta
[
'item'
]
item
=
NoticiasItem
()
item
=
NoticiasItem
()
# item['date'] = line['publishDate']
text
=
''
d
=
line
[
'publishDate'
]
if
len
(
d
)
==
10
:
news_date
=
response
.
url
[:
response
.
url
.
rfind
(
"/"
)]
d
=
map
(
int
,
d
.
split
(
'-'
))
news_date
=
news_date
[
news_date
.
rfind
(
"/"
)
+
1
:]
d
=
datetime
(
d
[
0
],
d
[
1
],
d
[
2
],
tzinfo
=
self
.
tz
)
.
isoformat
(
'T'
)
news_date
=
datetime
.
strptime
(
news_date
,
'
%
Y-
%
m-
%
d'
)
.
isoformat
(
"T"
)
elif
len
(
d
)
==
19
:
title
=
response
.
xpath
(
'//article/h1'
)
.
extract_first
()
d
,
t
=
d
.
split
(
' '
)
if
title
is
not
None
:
title
=
remove_tags
(
title
)
d
=
map
(
int
,
d
.
split
(
'-'
))
t
=
map
(
int
,
t
.
split
(
':'
))
d
=
datetime
(
d
[
0
],
d
[
1
],
d
[
2
],
t
[
0
],
t
[
1
],
t
[
2
],
tzinfo
=
self
.
tz
)
.
isoformat
(
'T'
)
item
[
'date'
]
=
d
topic
=
flow_info
[
'news_section'
]
.
capitalize
()
for
p
in
response
.
xpath
(
'//article'
)
.
css
(
'div.txt'
)
.
extract
():
text
+=
remove_tags
(
p
)
+
"
\n
"
## News item info ##
item
[
'date'
]
=
news_date
item
[
'title'
]
=
title
item
[
'topic'
]
=
topic
item
[
'topic'
]
=
topic
item
[
'title'
]
=
line
[
'name'
]
item
[
'text'
]
=
text
.
strip
()
if
not
(
response
.
url
[
response
.
url
.
rfind
(
'/'
)
+
1
:]
==
'notas?opinion'
):
item
[
'url'
]
=
response
.
url
request
=
scrapy
.
Request
(
url
=
self
.
baseURL
+
line
[
'url'
],
callback
=
self
.
parse_item
)
else
:
yield
item
request
=
scrapy
.
Request
(
url
=
self
.
baseURL
+
'/'
+
line
[
'publishDate'
][:
line
[
'publishDate'
]
.
rfind
(
' '
)]
+
'/'
+
line
[
'uriComponent'
],
callback
=
self
.
parse_item
)
request
.
meta
[
'item'
]
=
item
yield
request
def
parse_item
(
self
,
response
):
# para los json
def
parse_item_with_stop_date
(
self
,
response
):
item
=
response
.
meta
[
'item'
]
news_date
=
response
.
url
[:
response
.
url
.
rfind
(
"/"
)]
news_date
=
news_date
[
news_date
.
rfind
(
"/"
)
+
1
:]
news_date
=
datetime
.
strptime
(
news_date
,
'
%
Y-
%
m-
%
d'
)
.
date
()
if
news_date
>=
self
.
stop_date
:
flow_info
=
response
.
meta
[
'item'
]
item
=
NoticiasItem
()
text
=
''
text
=
''
for
paragraph
in
response
.
xpath
(
'//*[@class="txt"]'
)
.
extract
():
text
+=
remove_tags
(
paragraph
)
+
'
\n
'
news_date
=
datetime
.
strptime
(
news_date
.
isoformat
(),
'
%
Y-
%
m-
%
d'
)
.
isoformat
(
"T"
)
item
[
'text'
]
=
text
title
=
response
.
xpath
(
'//article/h1'
)
.
extract_first
()
if
title
is
not
None
:
title
=
remove_tags
(
title
)
topic
=
flow_info
[
'news_section'
]
.
capitalize
()
for
p
in
response
.
xpath
(
'//article'
)
.
css
(
'div.txt'
)
.
extract
():
text
+=
remove_tags
(
p
)
+
"
\n
"
## News item info ##
item
[
'date'
]
=
news_date
item
[
'title'
]
=
title
item
[
'topic'
]
=
topic
item
[
'text'
]
=
text
.
strip
()
item
[
'url'
]
=
response
.
url
item
[
'url'
]
=
response
.
url
print
item
[
'title'
]
yield
item
yield
item
if
flow_info
[
'is_last_link'
]:
flow_info
[
'to_next_page'
]
=
True
request
=
scrapy
.
Request
(
url
=
flow_info
[
'return_url'
],
callback
=
self
.
parse_with_stop_date_1
,
dont_filter
=
True
)
request
.
meta
[
'item'
]
=
flow_info
yield
request
descarga_hacia_atras/laJornadaMaya/scrapy.cfg
View file @
c908a556
# Automatically created by: scrapy startproject
# Automatically created by: scrapy startproject
#
#
# For more information about the [deploy] section see:
# For more information about the [deploy] section see:
# https://scrapyd.readthedocs.
org
/en/latest/deploy.html
# https://scrapyd.readthedocs.
io
/en/latest/deploy.html
[settings]
[settings]
default = laJornadaMaya.settings
default = laJornadaMaya.settings
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment