Probably a simple question, but I can’t figure out how, using the Docker API, I can pipe the result of reading a csv file into writing a csv file. My simple example is:

echo '{"type": "RECORD", "record": {"stream": "testing", "data": {"DOB": "01/02/1988", "First Name": "John", "Last NAME": "Jones"}, "emitted_at": 1650284493000}}' | docker run -v /Users/eliot/temp:/tmp airbyte/destination-csv write --catalog /tmp/airbyte_catalog.txt --config /tmp/airbyte_write.json

2022-04-19 14:47:36 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=/tmp/airbyte_catalog.txt, write=null, config=/tmp/airbyte_write.json}
2022-04-19 14:47:36 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Running integration: io.airbyte.integrations.destination.csv.CsvDestination
2022-04-19 14:47:36 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Command: WRITE
2022-04-19 14:47:36 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Integration config: IntegrationConfig{command=WRITE, configPath='/tmp/airbyte_write.json', catalogPath='/tmp/airbyte_catalog.txt', statePath='null'}
2022-04-19 14:47:36 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword