in container-code/src/rdslogsshipper.py [0:0]
def downloadRDSLogPortion (region, rdsClient, dbinst, logFileName, marker, LogFileData):
print ("Download RDS Log Portion for database instance {}, log file {}, marker {}".format(dbinst,logFileName, marker))
dwnldLogFilePortionResp = rdsClient.download_db_log_file_portion(DBInstanceIdentifier=dbinst, LogFileName=logFileName, Marker=marker)
print ("Response {}".format(dwnldLogFilePortionResp))
marker = dwnldLogFilePortionResp['Marker']
LogFileData = dwnldLogFilePortionResp['LogFileData']
if dwnldLogFilePortionResp['AdditionalDataPending']:
# More data exists, downlod the file again with new marker
downloadRDSLogPortion(region=region, rdsClient=rdsClient, dbinst=dbinst, logFileName=logFileName, marker=marker, LogFileData=LogFileData)
return LogFileData