parent
4c8f7fd11d
commit
ffb31bf2b1
@ -1,4 +1,5 @@
|
|||||||
defmodule Scrapper.Processor.MatchProcessor do
|
defmodule Scrapper.Processor.MatchProcessor do
|
||||||
|
require Logger
|
||||||
use Broadway
|
use Broadway
|
||||||
|
|
||||||
def start_link(_opts) do
|
def start_link(_opts) do
|
||||||
@ -48,6 +49,8 @@ defmodule Scrapper.Processor.MatchProcessor do
|
|||||||
match_url =
|
match_url =
|
||||||
case decoded_match.info.queueId do
|
case decoded_match.info.queueId do
|
||||||
420 ->
|
420 ->
|
||||||
|
Logger.info("#{match_id} #{decoded_match.info.gameVersion}")
|
||||||
|
|
||||||
Storage.MatchStorage.S3MatchStorage.store_match(
|
Storage.MatchStorage.S3MatchStorage.store_match(
|
||||||
match_id,
|
match_id,
|
||||||
raw_match,
|
raw_match,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user