alvaro/lol-analytics
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix match classifier

Browse Source
This commit is contained in:
Álvaro 2024-05-12 18:22:23 +02:00
parent ca75944558
commit b1605cef70
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/scrapper/lib/scrapper/match_classifier.ex
View File

@ -8,7 +8,7 @@ defmodule Scrapper.MatchClassifier do
@spec classify_match_by_queue(String.t()) :: nil @spec classify_match_by_queue(String.t()) :: nil
def classify_match_by_queue("420") do def classify_match_by_queue("420") do
matches = Storage.MatchStorage.S3MatchStorage.list_matches() matches = Storage.MatchStorage.S3MatchStorage.list_files("matches")
total_matches = Enum.count(matches) total_matches = Enum.count(matches)
matches matches
@ -16,7 +16,11 @@ defmodule Scrapper.MatchClassifier do
|> Scrapper.Parallel.peach(fn {match, index} -> |> Scrapper.Parallel.peach(fn {match, index} ->
%{key: json_file} = match %{key: json_file} = match
[key | _] = String.split(json_file, ".") [key | _] = String.split(json_file, ".")
response = HTTPoison.get!("http://#{System.get_env("EX_AWS_ENDPOINT")}:9000/matches/#{key}.json", [], timeout: 5000)
response =
HTTPoison.get!("http://#{System.get_env("EX_AWS_ENDPOINT")}:9000/matches/#{key}.json", [],
timeout: 5000
)
%{"info" => %{"gameVersion" => gameVersion, "queueId" => queueId}} = %{"info" => %{"gameVersion" => gameVersion, "queueId" => queueId}} =
Poison.decode!(response.body) Poison.decode!(response.body)