How to handle db queues using goroutine+channel

db writes 2000 to 5000 pieces of data per second, which you want to process at the expense of a daemon.
it must be too late to process one item at a time. I want to take advantage of goroutine+channel consumption. How can I get these data to ensure that the data obtained by each channel will not be duplicated?

Go
Jul.12,2022

first create a few blocked channel, and then hash it.

Menu