Pasarela RSS -> Twitter que también sube imágenes asociadas

 #!/usr/local/bin/python3

 # 20xx-2015 jcea@jcea.es - http://www.jcea.es/
 # Código liberado como Dominio Público.
 # Haz con él lo que quieras.

 import feedparser
 from bs4 import BeautifulSoup

 import urllib.request, urllib.parse
 import pickle
 import os, os.path
 import socket
 import fcntl
 import sys
 import functools

 path = '/home/blog-twitter/data/'
 persist = 'ya_publicados.pickle'

 def lock(f) :
     @functools.wraps(f)
     def wrapper() :
         # Si no puede, falla inmediatamente
         lock = open(persist+'.lock', 'a')
         fcntl.flock(lock, fcntl.LOCK_EX | fcntl.LOCK_NB)

         try :
             return f()
         finally :
             # El lock se libera automáticamente al terminar
             # pero así no dejamos basurilla en el directorio
             lock.close()
             os.remove(persist+".lock")
     return wrapper

 def drop_privileges() :
     os.chdir(path)
     os.setgroups([60001])  # Nobody
     os.setgid(60001)
     os.setuid(60001)

 def get_imgs_to_publish(url) :
     pagina = urllib.request.urlopen(url)
     if pagina.status != 200 :
         raise RuntimeError('La página %s devuelve el estado %s'
                 %(url, pagina.status))
     pagina = pagina.read()
     pagina = BeautifulSoup(pagina)
     pagina = pagina.select('.entry-content')
     if len(pagina) != 1 :
         raise RuntimeError('Formato inesperado')
     pagina = pagina[0]
     total_num_imgs = pagina('img')
     relevant_imgs = pagina('img', class_ = 'to-twitter')
     imgs = []
     if total_num_imgs :
         if len(relevant_imgs) == 0 :
             raise RuntimeError('Tenemos varias imágenes pero ninguna marcada '
                     'para ser publicada')
         for img in relevant_imgs :
             img_url = urllib.parse.urljoin(url, img['src'])
             imgs.append(img_url)
     return imgs

 def upload_images(images, auth) :
     import twitter  # Solo importa si lo vamos a necesitar

     # La imagen debe ser GIF, PNG o JPEG y medir menos de 3Mbytes.
     # XXX: Buscar una referencia online de esto.

     Twitter_upload = twitter.Twitter(domain='upload.twitter.com', auth=auth)

     ids = []
     for img in images :
         print('Subiendo imagen', img)
         img = urllib.request.urlopen(img)
         if img.status != 200 :
             raise RuntimeError('Intentar descargar la imagen %s devuelve el '
                 'estado %s' %(img.url, img.status))
         img = img.read()
         ids.append(str(Twitter_upload.media.upload(media=img)['media_id']))

     return ids

 def get_auth() :
     import twitter  # Solo importa si lo vamos a necesitar

     # Autenticacion OAUTH para TWITTER, segun los detalles de
     # http://jmillerinc.com/2010/05/31/twitter-from-the-command-line-in-python-using-oauth/
     # http://github.com/sixohsix/twitter/blob/master/twitter/ircbot.py
     consumer_key = "XXXXXX"
     consumer_secret = "XXXXXX"

     # Podemos crear un nuevo cliente en twitter y pedir que nos
     # genere unos token de acceso directamente, que podemos usar ya sin mas.
     if not os.path.exists('oauth_token_file') :
         from twitter.oauth_dance import oauth_dance
         oauth_dance('FEED RSS de http://blog.jcea.es/', consumer_key, consumer_secret,
                 "oauth_token_file")

     oauth_token, oauth_secret = \
         twitter.oauth.read_token_file('oauth_token_file')
     auth = twitter.OAuth(oauth_token, oauth_secret, consumer_key,
             consumer_secret)

     return auth

 @lock
 def do() :

     socket.setdefaulttimeout(60)

     ya_publicado = set()
     if os.path.exists(persist) :
         ya_publicado = pickle.load(open(persist, 'rb'))

     feed = feedparser.parse('https://blog.jcea.es/rss.xml')
     assert feed.status == 200
     assert feed.encoding == 'utf-8'

     limpieza = set([i.id for i in feed.entries])
     ya_publicado.intersection_update(limpieza)  # Limpieza de post antiguos
     a_publicar = [i for i in feed.entries if i.id not in ya_publicado]

     for entrada in a_publicar :
         import twitter  # Solo importa si lo vamos a necesitar

         auth = get_auth()

         twitter_API = twitter.Twitter(auth=auth)

         imgs = get_imgs_to_publish(entrada.link)
         if len(imgs) :
             imgs_ids = upload_images(imgs, auth = auth)
         else :
             imgs_ids = []

         # El 1 es por el espacio entre titulo y url
         # El acortamiento de t.co mide 22 bytes para HTTP y 23 bytes para HTTPS.
         # el 4 es por el ' #fb'
         l = 140-1-23-4

         params = {}
         if len(imgs_ids) :
             params['media_ids'] = ','.join(imgs_ids)
             # El enlace a las imágenes, aunque haya varias,
             # y el espacio previo.
             l -= 23+1

         titulo = entrada.title
         if len(titulo) > l :
             titulo = titulo[:l-3]+'...'

         # El acortamiento a 't.co' es automático y transparente, al
         # publicar en twitter.
         titulo = titulo+' '+entrada.link+' #fb'
         params['status'] = titulo

         try :
             twitter_API.statuses.update(**params)
         except twitter.api.TwitterHTTPError as e:
             import json
             e = json.loads(e.response_data.decode('utf-8'))
             if e['errors'][0]['message'] != 'Status is a duplicate.' :
                 raise

         print(titulo)

         ya_publicado.add(entrada.id)
         f = open(persist+'.new', 'wb')
         pickle.dump(ya_publicado, f)
         f.flush()
         os.fsync(f)
         f.close()
         os.rename(persist+'.new', persist)


 if __name__ == '__main__' :
     drop_privileges()
     do()