from pod_data_pipeline import PodDataPipeline
import json

if __name__ == '__main__':
    podPipe = PodDataPipeline()
    files = podPipe.generatePODFiles()
    for f in files:
        edata = podPipe.encryptBySignature(json.dumps(f["data"]))
        wf = open(f["name"], "wb")
        wf.write(edata)
        wf.close()
        # # write file into local
        podPipe.uploadS3(f)

f7fb15f5be048b98797e65085b35afcce4d0a291
<mask token>

<mask token>
if __name__ == '__main__':
    podPipe = PodDataPipeline()
    files = podPipe.generatePODFiles()
    for f in files:
        edata = podPipe.encryptBySignature(json.dumps(f['data']))
        wf = open(f['name'], 'wb')
        wf.write(edata)
        wf.close()
        podPipe.uploadS3(f)

from pod_data_pipeline import PodDataPipeline
import json
if __name__ == '__main__':
    podPipe = PodDataPipeline()
    files = podPipe.generatePODFiles()
    for f in files:
        edata = podPipe.encryptBySignature(json.dumps(f['data']))
        wf = open(f['name'], 'wb')
        wf.write(edata)
        wf.close()
        podPipe.uploadS3(f)

from pod_data_pipeline import PodDataPipeline
import json

if __name__ == '__main__':
    podPipe = PodDataPipeline()
    files = podPipe.generatePODFiles()
    for f in files:
        edata = podPipe.encryptBySignature(json.dumps(f["data"]))
        wf = open(f["name"], "wb")
        wf.write(edata)
        wf.close()
        # # write file into local
        podPipe.uploadS3(f)
