code: def query(self, query, **kwargs):
          
          params = {'q': query}
          response = requests.get(self._get_norm_query_url(),
                                  headers=self._get_rest_headers(),
                                  params=params,
                                  **kwargs)
          if response.status_code != requests.codes.ok:
              raise Exception(response.content)
  
          return response.json()
docs: Return the result of a Salesforce SOQL query as a dict decoded from the Salesforce response JSON payload.
  
          :param query: the SOQL query to send to Salesforce, e.g. "SELECT id from Lead WHERE email = 'a@b.com'"