지도제작 대회

투개표 API

공공데이터포털 투개표 API를 활용하여 선거데이터를 가져온다.

저자
소속

이광춘

한국 R 사용자회

1 데이터셋

1.1 1. 투표 데이터

1.1.1 국회의원 선거코드

코드
code_election <- krvote::code_election

names(code_election) <- c("선거코드", "선거명", "선거구분")

legislator_code <- code_election |> 
  dplyr::filter(str_detect(선거명, "국회의원")) |> 
  pull(선거코드) |> 
  unique()

legislator_code

1.1.2 국회의원 선거구

코드
legislator_raw <- code_election |> 
  dplyr::filter(str_detect(선거명, "국회의원"),
         선거구분 != "0") 

get_precinct <- function(legislator_cd = "20200415", sgTypecode = "2") {
  
  cat("\n---------------------------------------------\n")
  cat(" 선거코드: ", legislator_cd)
  cat("\n---------------------------------------------\n")
  
  # httr의 GET 함수로 데이터를 추출한다
  response <- GET("http://apis.data.go.kr/9760000/CommonCodeService/getCommonSggCodeList",
                  query = list(sgId = legislator_cd,
                               sgTypecode = sgTypecode,
                               numOfRows =  "1000",
                               resultType = "json",
                               serviceKey = Sys.getenv('DATA_GO_DECODE_KEY')))
  
  # 응답 상태와 내용을 확인한다
  # print(status_code(response))
  
  response_list <- content(response, "text") |> 
    fromJSON()
  
  response_tbl <- response_list$getCommonSggCodeList$item
  
  return(response_tbl |> as_tibble())
}

# get_precinct("20220309")

legislator_tbl <- legislator_raw |> 
  mutate(data = map2(선거코드, 선거구분, get_precinct))

legislator_tbl |> 
  write_rds("data/legislator_precinct_tbl.rds")

1.1.3 투표 API

코드
library(tidyverse)
library(httr)
library(jsonlite)

response <- GET("http://apis.data.go.kr/9760000/VoteXmntckInfoInqireService2/getVoteSttusInfoInqire",
                query = list(sgId = "20200415",
                             sgTypecode = "7",
                             sdName = "서울특별시",
                             wiwName = "종로구",
                             pageNo = "1",
                             numOfRows = "100",
                             resultType = "json",
                             serviceKey = Sys.getenv('DATA_GO_DECODE_KEY')))

# 응답 상태와 내용을 확인한다
print(status_code(response))

response_list <- content(response, "text") |> 
  fromJSON()

response_tbl <- response_list$getVoteSttusInfoInqire$item

response_tbl

1.1.4 투표 함수

코드
# 국회의원 선거구
legislator_precinct_tbl <- 
  read_rds("data/legislator_precinct_tbl.rds")

# legislator_precinct_tbl |> 
#   unnest(data)

get_wiw_cast <- function(sgId = "20200415", 
                         sdName = "서울특별시", wiwName = "종로구") {
  
  cat("\n---------------------------------------------\n")
  cat(" 선거코드: ", sgId, "\n")
  cat(" 시도명: ", sdName, "\n")
  cat(" 구시군명: ", wiwName, "\n")
  cat("---------------------------------------------\n")
  
  response <- GET("http://apis.data.go.kr/9760000/VoteXmntckInfoInqireService2/getVoteSttusInfoInqire",
                query = list(sgId = sgId,
                             sgTypecode = "7",
                             sdName = sdName,
                             wiwName = wiwName,
                             pageNo = "1",
                             numOfRows = "100",
                             resultType = "json",
                             serviceKey = Sys.getenv('DATA_GO_DECODE_KEY')))

  # 응답 상태와 내용을 확인한다
  # print(status_code(response))

  response_list <- content(response, "text") |>
    fromJSON()

  response_tbl <- response_list$getVoteSttusInfoInqire$item

  response_tbl
}

# get_wiw_cast()

get_wiw_cast_tbl <- function(sgId = "20200415") {
  
legislator_precinct_tbl |> 
  filter(선거구분 != "7") |> 
  dplyr::filter(선거코드 == sgId) |> 
  unnest(data) |> 
  # filter(str_detect(sdName, "제주")) |> 
  mutate(data = pmap( list(sgId, sdName, wiwName), get_wiw_cast))
}

# get_wiw_cast_tbl(sgId ="20200415")

# legislator_precinct_cast_tbl <- legislator_precinct_tbl |> 
#   filter(선거구분 == "2") |> 
#   mutate(cast_data = map(선거코드, get_wiw_cast_tbl))

legislator_election_code <- legislator_precinct_tbl |>
  filter(선거구분 == "2") |> 
  pull(선거코드)

for(i in seq_along(legislator_election_code)) {
  cat("\n---------------------------------------------\n")
  cat(" 선거코드: ", legislator_election_code[i], "\n")
  
  get_wiw_cast_tbl(legislator_election_code[i]) |>
    write_rds(str_glue("data/legislator_precinct_cast_{legislator_election_code[i]}.rds"))
}

1.1.5 정리

코드
data_filenames <- fs::dir_ls("data")

data_precinct_filenames <- data_filenames[str_detect(data_filenames, "data/legislator_precinct_cast_*")]

legislator_cast_tbl <- data_precinct_filenames |> 
  enframe() |> 
  mutate(data = map(value, read_rds)) |> 
  select(data) |> 
  unnest(data)

# 총선 투표율 데이터
legislator_cast_tbl |> 
  write_rds("data/legislator_cast_tbl.rds")

1.2 2. 득표 데이터

1.2.1 득표 API

코드
library(tidyverse)
library(httr)
library(jsonlite)

response <- GET("http://apis.data.go.kr/9760000/VoteXmntckInfoInqireService2/getXmntckSttusInfoInqire",
                query = list(sgId = "20200415",
                             sgTypecode = "7",
                             sdName = "서울특별시",
                             wiwName = "종로구",
                             pageNo = "1",
                             numOfRows = "100",
                             resultType = "json",
                             serviceKey = Sys.getenv('DATA_GO_DECODE_KEY')))

# 응답 상태와 내용을 확인한다
print(status_code(response))

response_list <- content(response, "text") |> 
  fromJSON()

response_tbl <- response_list$getXmntckSttusInfoInqire$item

response_tbl

1.2.2 득표 함수

1.2.2.1 선거구 함수

코드
# 국회의원 선거구
legislator_precinct_tbl <- 
  read_rds("data/legislator_precinct_tbl.rds")

legislator_precinct_tbl |>
  filter(선거코드 == "20220309") |> 
  unnest(data)

get_precinct_vote <- function(sgId = "20200415", 
                              sgTypecode = "2",
                              sdName = "서울특별시", sggName = "종로구") {
  
  cat("\n---------------------------------------------\n")
  cat(" 선거ID: ", sgId, "\n")
  cat(" 선거종류코드: ", sgTypecode, "\n")
  cat(" 시도명: ", sdName, "\n")
  cat(" 구시군명: ", sggName, "\n")
  cat("---------------------------------------------\n")
  
  response <- GET("http://apis.data.go.kr/9760000/VoteXmntckInfoInqireService2/getXmntckSttusInfoInqire",
                query = list(sgId = sgId,
                             sgTypecode = sgTypecode,
                             sdName = sdName,
                             sggName = sggName,
                             pageNo = "1",
                             numOfRows = "100",
                             resultType = "json",
                             serviceKey = Sys.getenv('DATA_GO_DECODE_KEY')))

  # 응답 상태와 내용을 확인한다
  # print(status_code(response))

  response_list <- content(response, "text") |>
    fromJSON()

  response_tbl <- response_list$getXmntckSttusInfoInqire$item

  response_tbl
}

get_precinct_vote()

1.2.2.2 총선 함수

코드
get_precinct_vote_tbl <- function(sgId = "20200415") {
  
  legislator_precinct_tbl |> 
    dplyr::filter(선거코드 == sgId) |> 
    dplyr::filter(선거구분 == "2") |>   # 지역구만 선정
    unnest(data) |> 
    # filter(str_detect(sdName, "제주")) |> 
    mutate(data = pmap( list(sgId, sgTypecode, sdName, sggName), get_precinct_vote))
}

vote_tbl <- get_precinct_vote_tbl()

vote_tbl

1.2.2.3 총선 전체 함수

코드
legislator_election_code <- legislator_precinct_tbl |>
  filter(선거구분 == "2") |> 
  mutate(선거구수 = map_int(data, nrow)) |> # 재보궐 제거
  filter(선거구수 > 100) |> 
  pull(선거코드)

for(i in seq_along(legislator_election_code)) {
  cat("\n---------------------------------------------\n")
  cat(" 선거코드: ", legislator_election_code[i], "\n")
  
  get_precinct_vote_tbl(legislator_election_code[i]) |>
    write_rds(str_glue("data/legislator_precinct_vote_{legislator_election_code[i]}.rds"))
}

safely(get_precinct_vote_tbl(legislator_election_code[4])) |>
  write_rds(str_glue("data/legislator_precinct_vote_{legislator_election_code[4]}.rds"))
코드
response <- GET("http://apis.data.go.kr/9760000/VoteXmntckInfoInqireService2/getXmntckSttusInfoInqire",
                query = list(sgId = "20160413",
                             sgTypecode = "2",
                             sdName = "경상남도",
                             wiwName = "통영시고성군",
                             pageNo = "1",
                             numOfRows = "100",
                             resultType = "json",
                             serviceKey = Sys.getenv('DATA_GO_DECODE_KEY')))

# 응답 상태와 내용을 확인한다
print(status_code(response))

response_list <- content(response, "text") |> 
  fromJSON()

response_tbl <- response_list$getXmntckSttusInfoInqire$item

response_tbl