როგორ შევასრულოთ მონაცემების მჭიდროდ გაგზავნა მონაცემების შენახვის სისტემაში?

მონაცემთა შენახვის სისტემებში, რომლებიც იყენებენ ნაწილობრივ (მაგალითად, Kafka, Cassandra), მონაცემების მყისიერად გადაგზავნა კონკრეტულ ნაწილში, აუცილებელია დაწერაზე ნაწილობრივი გასაღების ან ნაწილობრივი ნომრის ზუსტად მითითება.

Go-ში ეს ჩვეულებრივ ხდება მომხმარებლის API-ის საშუალებით, სადაც შეტყობინების გამოქვეყნების ან მონაცემების დაწერის დროს შეგიძლიათ განსაზღვროთ გასაღები ან ნაწილი:

// მაგალითი Kafka-სთვის sarama-ს გამოყენებით
producer.Input() <- &sarama.ProducerMessage{
    Topic: "ჩემი_თემა",
    Partition: 2, // ზუსტად მითითება ნაწილზე
    Key:   sarama.StringEncoder("ნაწილობრივი_გასაღები"),
    Value: sarama.StringEncoder("მონაცემები"),
}

თუ API პირდაპირ ნაწილობრივი ნომრის მითითებას არ აძლევს საშუალებას, შეიძლება განისაზღვროს ნაწილობრივი გასაღები, რომელიც ჰეშდება და განსაზღვრავს ნაწილს.

ამ გზით, მონაცემების მყისიერად გადაგზავნა საჭირო ნაწილში, საჭიროა გამოიყენოთ მომხმარებლის შესაძლებლობები, გასაღების ან ნაწილობრივი ნომრის მითითებისთვის დაწერის დროს.