Stream Processing

Hi,

I followed the steps provided in the Getting Started tutorial https://www.mongodb.com/docs/atlas/atlas-sp/tutorial/

At step 7. https://www.mongodb.com/docs/atlas/atlas-sp/tutorial/#create-a-persistent-stream-processor I have this error:

AtlasStreamProcessing> sp.createStreamProcessor(“avgWatts”, [s, t, m])
MongoServerError: Failed to create stream processor: (Location15955) a group specification must include an _id, correlationID = 179ed6d7e15a638fa3ae24c2
AtlasStreamProcessing>

Of course, I cannot proceed with the other steps since the stream processor failed:

Regards

Giampiero

Hi Giampiero,

Can you share your entire pipeline with us please? The values for s, t, and m.

Thanks!

Hi Joe,
it worked now… the pipeline was copied from the tutorial, maybe it was a mistake in copy and paste, I tried to copy a paste individually let s, u, g, t, m and finally sp.createStreamProcessor(“avgWatts”, [s, t, m]) and it worked:

AtlasStreamProcessing> sp.createStreamProcessor(“avgWatts”, [s, t, m])
Atlas Stream Processor: avgWatts

Thanks

Glad to hear it! Please let me know if you have any other questions or would like to get together to talk about your use case.