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
)