Публикация в Google Pub Sub асинхронно через Goroutine - PullRequest
Новая
       25

Публикация в Google Pub Sub асинхронно через Goroutine

0 голосов
/ 03 мая 2019

Я пытаюсь отправить сообщение в google pub-sub асинхронно через goroutine, но сталкиваюсь с ошибкой ниже panic: not an App Engine context Я использую mux и у меня есть обработчик API

n = 1 миллион 

    func apihandler(w http.ResponseWriter, r *http.Request) {
       go createuniquecodes(n)
       return "request running in background"
    }

    func createuniquecodes(n) {
       c := make(chan string)
       go createuniquecodes(c, n)  
       for val := range c {        
           publishtopubsub(val)
       } 
   }
   func createuniquecodes(n) {
        for i := 0; i < n; i++ {
           uniquecode := some random string
           // publish to channel and pubsub
           c <- uniquecode
        }
        close(c)
   } 

func publishuq(msg string) error {
   ctx := context.Background()
   client, err := pubsub.NewClient(ctx, projectId)
   if err != nil {
     log.Fatalf("Could not create pubsub Client: %v", err)
   }
   t := client.Topic(topicName)
   result := t.Publish(ctx, &pubsub.Message{
   Data: []byte(msg),
 })
 id, err := result.Get(ctx)
 if err != nil {
    return err
}
fmt.Printf("Published a message; msg ID: %v\n", id)
return nil

}

Обратите внимание, что мне нужно сгенерировать 5 миллионов уникальных кодов. Как мне определить контекст в процедуре go, поскольку я делаю все асинхронно

1 Ответ

1 голос
/ 03 мая 2019

Я предполагаю, что вы используете стандартную (не гибкую) среду App Engine.Обратите внимание, что «обработчик запроса (apihandler в вашем случае) имеет ограниченное количество времени для генерации и возврата ответа на запрос, обычно около 60 секунд . После того, как крайний срок будет достигнут,обработчик запроса прерван ".

Вы пытаетесь «разорвать» запрос при вызове go createuniquecodes(n), а затем ctx := context.Background() по линии - это то, что паникует при not an App Engine context.Технически вы можете использовать NewContext (req * http.Request) для получения действительного контекста из исходного контекста, но, опять же, у вас будет только 60 секунд до истечения времени ожидания вашего запроса.

Пожалуйставзгляните на TaskQueues , поскольку они «позволяют приложениям выполнять работу, называемую задачами, асинхронно вне пользовательского запроса».

...