code: def read_data(self, **kwargs):
          
          date_triggered = kwargs.get('date_triggered')
          trigger_id = kwargs.get('trigger_id')
          kwargs['model_name'] = 'Rss'
          kwargs['app_label'] = 'django_th'
          # get the URL from the trigger id
          rss = super(ServiceRss, self).read_data(**kwargs)
  
          logger.debug("RSS Feeds from %s : url %s", rss.name, rss.url)
  
          now = arrow.utcnow().to(settings.TIME_ZONE)
          my_feeds = []
  
          # retrieve the data
          feeds = Feeds(**{'url_to_parse': rss.url}).datas()
  
          for entry in feeds.entries:
              # entry.*_parsed may be None when the date in a RSS Feed is invalid
              # so will have the "now" date as default
              published = self._get_published(entry)
              if published:
                  published = arrow.get(str(published)).to(settings.TIME_ZONE)
              date_triggered = arrow.get(str(date_triggered)).to(settings.TIME_ZONE)
              if date_triggered is not None and published is not None and now >= published >= date_triggered:
                  my_feeds.append(entry)
                  # digester
                  self.send_digest_event(trigger_id, entry.title, entry.link)
  
          cache.set('th_rss_' + str(trigger_id), my_feeds)
          cache.set('th_rss_uuid_{}'.format(rss.uuid), my_feeds)
          # return the data
          return my_feeds
docs: get the data from the service
  
              :param kwargs: contain keyword args : trigger_id and model name
              :type kwargs: dict
              :rtype: dict