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.

MySQL Query : SELECT * FROM `codeshelper`.`v9_news` WHERE status=99 AND catid='6' ORDER BY rand() LIMIT 5
MySQL Error : Disk full (/tmp/#sql-temptable-64f5-1ec9cf0-2f7e.MAI); waiting for someone to free some space... (errno: 28 "No space left on device")
MySQL Errno : 1021
Message : Disk full (/tmp/#sql-temptable-64f5-1ec9cf0-2f7e.MAI); waiting for someone to free some space... (errno: 28 "No space left on device")
Need Help?