методы API

import pandas as pd
import requests

TOKEN = "rst_ваш_токен"
resp = requests.get(
    "https://rustata.ru/api/v1/data",
    params={"dataset": "fedstat/indicator_31448", "class": "3203",
            "geo": "region", "start": "2024-01"},
    headers={"Authorization": f"Bearer {TOKEN}"},
    timeout=60,
)
resp.raise_for_status()
payload = resp.json()

series = pd.DataFrame(payload["series"]).set_index("series_key")
obs = pd.DataFrame(payload["observations"])
obs["region"] = obs["series_key"].map(series["geo_label"])
obs["period"] = pd.to_datetime(obs["period"])

table = obs.pivot(index="period", columns="region", values="value")
print(table.tail())

# у тарифов без месячной квоты этого заголовка нет, поэтому .get, а не []
print("остаток квоты:", resp.headers.get("X-Quota-Values-Remaining", "без ограничения"))

library(httr)
library(readr)
library(tidyr)

# Windows: если консоль печатает кириллицу как <U+0411><U+0435>…, дело в локали сессии,
# а не в данных - сами строки целы. Лечится одной строкой:
if (.Platform$OS.type == "windows") Sys.setlocale("LC_CTYPE", "Russian_Russia.utf8")

token <- "rst_ваш_токен"
resp <- GET(
  "https://rustata.ru/api/v1/data",
  query = list(dataset = "fedstat/indicator_31448", class = "3203",
               geo = "region", start = "2024-01", format = "csv"),
  add_headers(Authorization = paste("Bearer", token))
)
stop_for_status(resp)

# content(resp, "raw") + locale(): readr сам разбирает UTF-8, без промежуточной строки
df <- read_delim(content(resp, "raw"), delim = ";",
                 locale = locale(encoding = "UTF-8"), show_col_types = FALSE)
table <- pivot_wider(df, id_cols = period, names_from = geo_label, values_from = value)
head(table)

using HTTP, CSV, DataFrames

token = "rst_ваш_токен"
resp = HTTP.get("https://rustata.ru/api/v1/data";
    query = Dict("dataset" => "fedstat/indicator_31448", "class" => "3203",
                 "geo" => "region", "start" => "2024-01", "format" => "csv"),
    headers = ["Authorization" => "Bearer $token"])

df = CSV.read(IOBuffer(resp.body), DataFrame; delim = ';')
table = unstack(df, :period, :geo_label, :value)
first(table, 5)

import requests

TOKEN = "rst_ваш_токен"
resp = requests.get(
    "https://rustata.ru/api/v1/series/search",
    params={"q": "бензин аи-92", "limit": 5},
    headers={"Authorization": f"Bearer {TOKEN}"}, timeout=30,
)
resp.raise_for_status()

for item in resp.json()["items"]:
    print(item["series_key"], "|", item["title"])

library(httr)
library(jsonlite)

token <- "rst_ваш_токен"
resp <- GET("https://rustata.ru/api/v1/series/search",
            query = list(q = "бензин аи-92", limit = 5),
            add_headers(Authorization = paste("Bearer", token)))
stop_for_status(resp)

items <- fromJSON(content(resp, "text", encoding = "UTF-8"))$items
items[, c("series_key", "title")]

using HTTP, JSON3

token = "rst_ваш_токен"
resp = HTTP.get("https://rustata.ru/api/v1/series/search";
    query = Dict("q" => "бензин аи-92", "limit" => 5),
    headers = ["Authorization" => "Bearer $token"])

for item in JSON3.read(resp.body).items
    println(item.series_key, " | ", item.title)
end

import pandas as pd
import requests

TOKEN = "rst_ваш_токен"
KEY = "s1_mydzoqiytm4xqjq3"
resp = requests.get(
    f"https://rustata.ru/api/v1/series/{KEY}/observations",
    params={"start": "2024-01"},
    headers={"Authorization": f"Bearer {TOKEN}"}, timeout=30,
)
resp.raise_for_status()

df = pd.DataFrame(resp.json()["observations"])
df["period"] = pd.to_datetime(df["period"])
print(df.set_index("period")["value"].tail())

library(httr)
library(jsonlite)

token <- "rst_ваш_токен"
key <- "s1_mydzoqiytm4xqjq3"
resp <- GET(paste0("https://rustata.ru/api/v1/series/", key, "/observations"),
            query = list(start = "2024-01"),
            add_headers(Authorization = paste("Bearer", token)))
stop_for_status(resp)

obs <- fromJSON(content(resp, "text", encoding = "UTF-8"))$observations
tail(obs[, c("period", "value")])

using HTTP, JSON3, DataFrames

token = "rst_ваш_токен"
key = "s1_mydzoqiytm4xqjq3"
resp = HTTP.get("https://rustata.ru/api/v1/series/$key/observations";
    query = Dict("start" => "2024-01"),
    headers = ["Authorization" => "Bearer $token"])

obs = DataFrame(JSON3.read(resp.body).observations)
last(obs, 5)

import requests

TOKEN = "rst_ваш_токен"
KEY = "s1_mydzoqiytm4xqjq3"
resp = requests.get(
    f"https://rustata.ru/api/v1/series/{KEY}/evidence",
    headers={"Authorization": f"Bearer {TOKEN}"}, timeout=30,
)
resp.raise_for_status()

for release in resp.json()["releases"][:3]:
    print(release["published_at"], "|", release["source_file"])

library(httr)
library(jsonlite)

token <- "rst_ваш_токен"
key <- "s1_mydzoqiytm4xqjq3"
resp <- GET(paste0("https://rustata.ru/api/v1/series/", key, "/evidence"),
            add_headers(Authorization = paste("Bearer", token)))
stop_for_status(resp)

releases <- fromJSON(content(resp, "text", encoding = "UTF-8"))$releases
head(releases[, c("published_at", "source_file")], 3)

using HTTP, JSON3

token = "rst_ваш_токен"
key = "s1_mydzoqiytm4xqjq3"
resp = HTTP.get("https://rustata.ru/api/v1/series/$key/evidence";
    headers = ["Authorization" => "Bearer $token"])

for release in JSON3.read(resp.body).releases[1:min(3, end)]
    println(release.published_at, " | ", release.source_file)
end

import requests

TOKEN = "rst_ваш_токен"
headers = {"Authorization": f"Bearer {TOKEN}"}

found = requests.get("https://rustata.ru/api/v1/concepts/search",
                     params={"q": "молоко", "limit": 3},
                     headers=headers, timeout=30).json()
for concept in found["items"]:
    print(concept["concept_id"], "|", concept["label"], "|", concept["series_count"], "рядов")

first_id = found["items"][0]["concept_id"]
card = requests.get(f"https://rustata.ru/api/v1/concepts/{first_id}",
                    headers=headers, timeout=30).json()
print(card["label"], "- территорий:", card.get("geo_count"))

library(httr)
library(jsonlite)

token <- "rst_ваш_токен"
auth <- add_headers(Authorization = paste("Bearer", token))

found <- fromJSON(content(GET("https://rustata.ru/api/v1/concepts/search",
                              query = list(q = "молоко", limit = 3), auth),
                          "text", encoding = "UTF-8"))
found$items[, c("concept_id", "label", "series_count")]

card <- fromJSON(content(GET(paste0("https://rustata.ru/api/v1/concepts/",
                                    found$items$concept_id[1]), auth),
                         "text", encoding = "UTF-8"))
card$label

using HTTP, JSON3

token = "rst_ваш_токен"
auth = ["Authorization" => "Bearer $token"]

found = JSON3.read(HTTP.get("https://rustata.ru/api/v1/concepts/search";
    query = Dict("q" => "молоко", "limit" => 3), headers = auth).body)
for concept in found.items
    println(concept.concept_id, " | ", concept.label, " | ", concept.series_count)
end

card = JSON3.read(HTTP.get("https://rustata.ru/api/v1/concepts/$(found.items[1].concept_id)";
    headers = auth).body)
println(card.label)

import pandas as pd
import requests

TOKEN = "rst_ваш_токен"
headers = {"Authorization": f"Bearer {TOKEN}"}
BASE = "https://rustata.ru/api/v1"

codes = pd.DataFrame(requests.get(f"{BASE}/reference/codes",
                                  params={"dataset": "fedstat/indicator_31448"},
                                  headers=headers, timeout=60).json()["items"])
beer = codes[codes["name"].str.contains("Пиво", case=False)]
print(beer[["class", "name"]])

# коды списком - один запрос вместо запроса на каждый продукт
data = requests.get(f"{BASE}/data",
                    params={"dataset": "fedstat/indicator_31448",
                            "class": ",".join(beer["class"]),
                            "geo": "region", "start": "2024-01"},
                    headers=headers, timeout=120).json()
print(data["series_total"], "рядов")

library(httr)
library(jsonlite)

token <- "rst_ваш_токен"
auth <- add_headers(Authorization = paste("Bearer", token))
base <- "https://rustata.ru/api/v1"

codes <- fromJSON(content(GET(paste0(base, "/reference/codes"),
                              query = list(dataset = "fedstat/indicator_31448"), auth),
                          "text", encoding = "UTF-8"))$items
beer <- codes[grepl("Пиво", codes$name, ignore.case = TRUE), ]
beer[, c("class", "name")]

data <- fromJSON(content(GET(paste0(base, "/data"),
                             query = list(dataset = "fedstat/indicator_31448",
                                          class = paste(beer$class, collapse = ","),
                                          geo = "region", start = "2024-01"), auth),
                         "text", encoding = "UTF-8"))
data$series_total

using HTTP, JSON3, DataFrames

token = "rst_ваш_токен"
auth = ["Authorization" => "Bearer $token"]
base = "https://rustata.ru/api/v1"

codes = DataFrame(JSON3.read(HTTP.get("$base/reference/codes";
    query = Dict("dataset" => "fedstat/indicator_31448"), headers = auth).body).items)
beer = filter(row -> occursin("Пиво", row.name), codes)

data = JSON3.read(HTTP.get("$base/data";
    query = Dict("dataset" => "fedstat/indicator_31448",
                 "class" => join(beer.class, ","),
                 "geo" => "region", "start" => "2024-01"), headers = auth).body)
println(data.series_total, " рядов")