⛵️ 🤸🏻 👆🏼 Obtendo estatísticas para todos os clientes da API Yandex.Direct por dias usando Python ✍🏿 📹 👨🏾‍⚕️

No meu trabalho, costumo usar estatísticas curtas por dia para rastrear desvios de tráfego.

Ele escreveu mais sobre como escrever solicitações no artigo "Obtendo campanhas de publicidade direta Yandex.Direct usando uma API em um DataFrame (Python)" .

Neste artigo, falarei mais sobre como estruturar dados e consultas para que possam ser usados normalmente.

Devemos registrar a solicitação do servidor como uma função.

Pessoalmente, criei 2 arquivos: uma função com uma solicitação e um arquivo com dados que serão transferidos para a função.

No primeiro arquivo, escrevemos uma função

Solicito os mesmos campos para todos os projetos, portanto, preciso passar nas datas da solicitação apenas, login e token.

Passar dados para uma função para mim é assim:

def rep(token,login,date_from,date_to):

Estamos escrevendo uma solicitação para o servidor da API Yandex.Direct

Esta consulta solicita dados para os seguintes parâmetros:

Data
Impressões
Cliques
Ctr
Custo
Avgcpc
AvgImpressionPosition
AvgClickPosition
AvgTrafficVolume
Bouncerate
AvgPageviews

O arquivo de solicitação final

Código

 import requests from requests.exceptions import ConnectionError from time import sleep import json #        UTF-8   Python 3,    Python 2 import sys def rep(token,login,date_from,date_to): if sys.version_info < (3,): def u(x): try: return x.encode("utf8") except UnicodeDecodeError: return x else: def u(x): if type(x) == type(b''): return x.decode('utf8') else: return x # ---   --- #   Reports   JSON- () ReportsURL = 'https://api.direct.yandex.com/json/v5/reports' # OAuth- ,       token = token #     #  ,        clientLogin = login # ---   --- #  HTTP-  headers = { # OAuth-.   Bearer  "Authorization": "Bearer " + token, #     "Client-Login": clientLogin, #    "Accept-Language": "ru", #    "processingMode": "auto" #      # "returnMoneyInMicros": "false", #            # "skipReportHeader": "true", #         # "skipColumnHeader": "true", #          # "skipReportSummary": "true" } #    body = { "params": { "SelectionCriteria": { "DateFrom": date_from, "DateTo": date_to }, "FieldNames": [ "Date", "Impressions", "Clicks", "Ctr", "Cost", "AvgCpc", "AvgImpressionPosition", "AvgClickPosition", "AvgTrafficVolume", "BounceRate", "AvgPageviews", ], "ReportName": u("Report4"), "ReportType": "ACCOUNT_PERFORMANCE_REPORT", "DateRangeType": "CUSTOM_DATE", "Format": "TSV", "IncludeVAT": "NO", "IncludeDiscount": "NO" } } #     JSON body = json.dumps(body, indent=4) # ---      --- #   HTTP- 200,     #   HTTP- 201  202,    while True: try: req = requests.post(ReportsURL, body, headers=headers) req.encoding = 'utf-8' #      UTF-8 if req.status_code == 400: print("         ") print("RequestId: {}".format(req.headers.get("RequestId", False))) print("JSON- : {}".format(u(body))) print("JSON-  : \n{}".format(u(req.json()))) break elif req.status_code == 200: format(u(req.text)) break elif req.status_code == 201: print("       ") retryIn = int(req.headers.get("retryIn", 60)) print("    {} ".format(retryIn)) print("RequestId: {}".format(req.headers.get("RequestId", False))) sleep(retryIn) elif req.status_code == 202: print("    ") retryIn = int(req.headers.get("retryIn", 60)) print("    {} ".format(retryIn)) print("RequestId: {}".format(req.headers.get("RequestId", False))) sleep(retryIn) elif req.status_code == 500: print("    . ,    ") print("RequestId: {}".format(req.headers.get("RequestId", False))) print("JSON-  : \n{}".format(u(req.json()))) break elif req.status_code == 502: print("     .") print( ",     -      .") print("JSON- : {}".format(body)) print("RequestId: {}".format(req.headers.get("RequestId", False))) print("JSON-  : \n{}".format(u(req.json()))) break else: print("  ") print("RequestId: {}".format(req.headers.get("RequestId", False))) print("JSON- : {}".format(body)) print("JSON-  : \n{}".format(u(req.json()))) break #  ,       API  except ConnectionError: #         print("     API") #     break #   -   except: #         print("  ") #     break json_string = json.dumps(body) return req.text

2 arquivos

Retiramos as datas, logins e tokens separadamente como variáveis.

Algo assim:

 # mytoken='blablablablaBLABLAsdfgsrgkdfgnf' # project = 'elama-99999999' # DateFrom="2019-04-08" DateTo="2019-04-16"

Isso é feito para alterar facilmente as informações de todos os clientes e as datas dos relatórios.

Código para solicitar estatísticas do projeto

 print( '\n=== ===') data=rep(mytoken,project,DateFrom,DateTo) file=open("cashe.csv","w") file.write(data) file.close() f=DataFrame.from_csv("cashe.csv",header=1,sep=' ',index_col=0,parse_dates=True) f['Cost']=f['Cost']*1.2 f['Cost']=f['Cost']/1000000 f['AvgCpc']=f['AvgCpc']*1.2 f['AvgCpc']=f['AvgCpc']/1000000 print(f)

Mais detalhes:

O nome do projeto ("=" usamos para uma melhor seleção, para não nos perdermos nas informações)
Dados - Escreva nesta linha as variáveis que já estão indicadas acima. (esta linha executará o primeiro arquivo)
Escrevemos a resposta do servidor para um arquivo
Abra o arquivo como um DataFrame
Adicione aos valores monetários do IVA.
Traduzimos os valores monetários em rublos comuns (como padrão, a API não usa rublos, mas rublos * 1.000.000.
Saída do nosso DataFrame

O segundo arquivo é o seguinte: