问如何使用Python创建报表
EN

Stack Overflow用户

提问于 2022-11-25 03:16:40

回答 1查看 32关注 0票数 1

我试图用Python在dailymotion上创建报告，但是我有错误，根据我收到的错误，renponse是空的。我还是不明白。我想，我的用户不能登录到dailymotion。请检查错误。

{“数据”：{“askPartnerReportFile”：无}，“错误”：[{“消息”：“未授权访问askPartnerReportFile字段”。)，“路径”：“askPartnerReportFile”，“位置”：{'line'：3，'column'：9}，**'type'：‘not_authorized**’}}回溯(最近一次调用)：

文件"get_reports.py"，第143行，在product='CONTENT‘中，

文件"get_reports.py"，第65行，在create_report_request中返回response.json()'data''reportFile'；

TypeError：“NoneType”对象不可订阅

这是我的密码；

    def get_access_token(app_key, app_secret, username, password):
        '''
        Authenticate on the API in order to get an access token
        '''
        response = requests.post('https://graphql.api.dailymotion.com/oauth/token', data={
            'client_id': app_key,
            'client_secret': app_secret,
            'username': username,
            'password': password,
            'grant_type': 'password',
            'version': '2'
        })
    
        if response.status_code != 200 or not 'access_token' in response.json():
            raise Exception('Invalid authentication response')
    
        return response.json()['access_token']
    
    def create_report_request(access_token, dimensions, metrics, start_date, end_date, product, filters = None):
        '''
        Creating a report request
        '''
        reportRequest = """
        mutation ($input: AskPartnerReportFileInput!) {
            askPartnerReportFile(input: $input) {
                reportFile {
                    reportToken
                }
            }
        }
        """
        response = requests.post(
            'https://graphql.api.dailymotion.com',
            json={
                'query': reportRequest,
                'variables': {
                    'input': {
                        'metrics': metrics,
                        'dimensions': dimensions,
                        'filters': filters,
                        'startDate': start_date,
                        'endDate': end_date,
                        'product': product,
                    }
                }
            },
            headers={'Authorization': 'Bearer ' + access_token}
        )
        print(response.status_code)
        if response.status_code != 200 or not 'data' in response.json():
            raise Exception('Invalid response')
        print(response.json())
        return response.json()['data']['askPartnerReportFile']['reportFile']['reportToken'];
    
    def check_report_status(access_token, report_token):
        '''
        Checking the status of the reporting request
        '''
        report_request_status_check = """
        query PartnerGetReportFile ($reportToken: String!) {
            partner {
                reportFile(reportToken: $reportToken) {
                    status
                    downloadLinks {
                        edges {
                            node {
                                link
                            }
                        }
                    }
                }
            }
        }
        """
        response = requests.post(
            'https://graphql.api.dailymotion.com',
            json={
                'query': report_request_status_check,
                'variables': {
                    'reportToken': report_token
                }
            },
            headers={'Authorization': 'Bearer ' + access_token}
        )
    
        if response.status_code != 200 or not 'data' in response.json():
            raise Exception('Invalid response')
    
        status = response.json()['data']['partner']['reportFile']['status'];
    
        if (status == 'FINISHED'):
            download_links = []
            for url in map(lambda edge: edge['node']['link'], response.json()['data']['partner']['reportFile']['downloadLinks']['edges']):
                download_links.append(url)
            return download_links
        else:
            return None
    
    def download_report(download_links, base_path=None):
        '''
        Downloading the report files
        '''
        cpt = 1
        if not base_path:
            base_path = os.getcwd()
    
        for url in download_links:
            r = requests.get(url)
            filename = 'report_{}.csv'.format(cpt)
            file_path = os.path.join(base_path, filename)
            open(file_path, 'wb').write(r.content)
            print('Report file {} downloaded: {}'.format(cpt, file_path))
            cpt += 1
    
    print('Generating access token...')
    access_token = get_access_token(
        app_key='******',
        app_secret='*******',
        username='*****',
        password='*****'
    )
    
    print('Creating report request...')
    report_token = create_report_request(
        access_token=access_token,
        dimensions=('DAY', 'VIDEO_TITLE'),
        metrics=('VIEWS'),
        filters={'videoOwnerChannelSlug': 'B******'},
        start_date='2022-11-23',
        end_date='2022-11-24',
        product='CONTENT',
    )
    
    download_links = None
    while not download_links:
        print('Checking report status...')
        # Checks every 15secs the report status
        time.sleep(15)
        download_links = check_report_status(
            access_token=access_token,
            report_token=report_token
        )
    
    download_report(download_links=download_links)