code: def run(self):
          
          kwargs = {'query': self.get_data()}
          if self.data_type == "ip":
              kwargs.update({'query_type': 'ip'})
          elif self.data_type == "network":
              kwargs.update({'query_type': 'network'})
          elif self.data_type == 'autonomous-system':
              kwargs.update({'query_type': 'asn'})
          elif self.data_type == 'port':
              kwargs.update({'query_type': 'port'})
          else:
              self.notSupported()
              return False
  
          if self.service == 'observations':
              response = self.bs.get_observations(**kwargs)
              self.report(response)
          elif self.service == 'enrichment':
              response = self.bs.enrich(**kwargs)
              self.report(response)
          else:
              self.report({'error': 'Invalid service defined.'})
docs: Run the process to get observation data from Backscatter.io.