Unverified Commit cae03ea7 authored by Bennett Piater's avatar Bennett Piater
Browse files

add all images

parent fa2fe959
......@@ -50,8 +50,26 @@ async function main() {
// Submit all images to kafka
let img1 = await loadFromCouchDB("1.jpg")
let img2 = await loadFromCouchDB("2.jpg")
let img3 = await loadFromCouchDB("3.jpg")
let img4 = await loadFromCouchDB("4.jpg")
let img5 = await loadFromCouchDB("5.jpg")
let img6 = await loadFromCouchDB("6.jpg")
let img7 = await loadFromCouchDB("7.jpg")
let img8 = await loadFromCouchDB("8.jpg")
let img9 = await loadFromCouchDB("9.jpg")
let img10 = await loadFromCouchDB("10.jpg")
// console.log(img1)
writeToKafka("topic1", "1.jpg", JSON.stringify(img1)).catch(e => console.error(e))
writeToKafka("topic1", "2.jpg", JSON.stringify(img2)).catch(e => console.error(e))
writeToKafka("topic1", "3.jpg", JSON.stringify(img3)).catch(e => console.error(e))
writeToKafka("topic1", "4.jpg", JSON.stringify(img4)).catch(e => console.error(e))
writeToKafka("topic1", "5.jpg", JSON.stringify(img5)).catch(e => console.error(e))
writeToKafka("topic1", "6.jpg", JSON.stringify(img6)).catch(e => console.error(e))
writeToKafka("topic1", "7.jpg", JSON.stringify(img7)).catch(e => console.error(e))
writeToKafka("topic1", "8.jpg", JSON.stringify(img8)).catch(e => console.error(e))
writeToKafka("topic1", "9.jpg", JSON.stringify(img9)).catch(e => console.error(e))
writeToKafka("topic1", "10.jpg", JSON.stringify(img10)).catch(e => console.error(e))
let start = new Date()
// TODO: wait until all images are in CouchDB
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment