def execute()

in mwaairflow/assets/plugins/operators/salesforce_to_s3_operator.py [0:0]


    def execute(self, context):
        sf_conn = SalesforceHook(self.sf_conn_id).get_conn()

        logging.info(self.soql)
        query_results = sf_conn.bulk.__getattr__(self.object).query(self.soql)

        s3 = S3Hook(self.s3_conn_id)
        # One JSON Object Per Line
        query_results = [
            json.dumps(result, ensure_ascii=False) for result in query_results
        ]
        query_results = "\n".join(query_results)

        s3.load_string(
            query_results, self.s3_key, bucket_name=self.s3_bucket, replace=True
        )