(key string, provider string)
| 80 | } |
| 81 | |
| 82 | func genAIKey(key string, provider string) string { |
| 83 | keys := strings.Split(key, "@") |
| 84 | return strings.TrimPrefix(keys[0], fmt.Sprintf("%s-", provider)) |
| 85 | } |
| 86 | |
| 87 | // HandleMessage 处理从 NSQ 读取的消息 |
| 88 | func (h *NSQHandler) HandleMessage(message *nsq.Message) error { |