文档首页/ 内容分发网络 CDN/ 最佳实践/ 使用函数工作流服务实现CDN日志转存到OBS
更新时间：2024-07-03 GMT+08:00
查看PDF
分享

使用函数工作流服务实现CDN日志转存到OBS

方案概述

CDN记录了所有域名（包括已删除域名，如果您开通了企业项目，则已删除域名不支持此功能）被网络用户访问的详细日志，您可以通过CDN控制台查看和下载最近30天的日志，对您的业务资源被访问情况进行详细分析。

日志转存储服务是华为云CDN配合函数工作流，将CDN日志存储到OBS桶，可以帮助您将日志存储更长的时间，便于您基于长时间的日志做出自定义的数据分析，有助于您更好地了解您CDN的服务质量，以及您的终端客户的访问详情，提高您的业务决策能力。

本文以Python3.6为例，为您介绍通过控制台创建FunctionGraph函数和Timer触发器，实现定时将CDN日志转存到OBS。

资源与成本规划

本实践所需资源请见下表。

资源

资源说明

每月费用

内容分发网络 CDN

流量：用户访问CDN节点产生的流量，可购买流量包抵扣。

具体的计费方式及标准请参考计费说明。

对象存储服务 OBS

存储费用：日志存储费用，按需计费。

具体的计费方式及标准请参考OBS计费说明。

函数工作流 FunctionGraph

请求次数费用、执行时间费用和其他费用，按需计费。

具体的计费方式及标准请参考函数工作流计费项

实施步骤

  1. 当前仅支持日志转存到北京四的OBS桶，需提前准备好位于华北-北京四的OBS桶。
    1. 登录华为云控制台，在左侧导航栏，选择“存储>对象存储服务 OBS”。
    2. 单击右上方“创建桶”按钮，进入创建桶页面。
      • 复制桶配置：不设置。
      • 区域：华北-北京四。
      • 桶名称：cdnlog。
      • 数据冗余存储策略：多AZ存储。
      • 默认存储类别：标准存储。
      • 桶策略：公共读。
    3. 配置上述参数，单击“立即创建”，完成桶创建。
  2. 创建自定义策略
    1. 登录华为云控制台，在左侧导航栏，选择“管理与监管>统一身份认证服务”。
    2. 在左侧导航栏，选择“权限管理>权限”页签，单击右上方的“创建自定义策略”。
      • 策略名称：OBS OperateAccess。
      • 策略配置方式：JSON视图。
      • 策略内容： 
        {
    "Version": "1.1",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "obs:object:GetObject",
                "obs:object:PutObjectAcl",
                "obs:bucket:HeadBucket",
                "obs:object:PutObject",
                "obs:bucket:ListBucket"
            ]
        }
    ]
}
    3. 单击“确定”，完成策略配置。
  3. 创建委托
    1. 登录华为云控制台，在左侧导航栏，选择“管理与监管>统一身份认证服务”。
    2. 在左侧导航栏，选择“委托”页签，单击右上方的“创建委托”。
    3. 在创建委托页面，按照如下参数设置委托。
      • 委托名称：FG_TO_CDN。
      • 委托类型：云服务。
      • 云服务：函数工作流FunctionGraph。
      • 持续时间：永久。
    4. 单击“下一步”，进入为“FG_TO_CDN”委托配置权限界面。
      • 权限选择：OBS OperateAccess（第一步创建的策略） 、CDN LogsReadOnlyAccess。

    5. 单击“下一步”，配置作用范围。
      1. 账号未开通企业项目，配置如下：
        • 作用范围：所有资源。

      2. 账号已开通企业项目，配置如下：
        • 作用范围：指定企业项目资源。

      3. 选择存放日志的OBS桶所在的企业项目。
    6. 单击“确认”，完成委托配置。
  4. 准备函数工作流环境
    1. 登录华为云控制台，在左侧导航栏，选择“计算>函数工作流”，region选择“北京四”。
    2. 单击右上方“创建函数”，进入创建函数界面，选择“空白模板”。
      • 函数类型：事件函数。
      • 输入函数名称：cdn_to_obs（可自定义）。
      • 委托名称：选择已创建好的委托“FG_TO_CDN” 。
      • 企业项目：选择“default”。
      • 运行时语言：选择“Python 3.6”。

    1. 单击“创建函数”，进入代码编辑界面，将代码示例的代码内容贴入在线IDE。

      如果有多个域名的日志需要转存，您需要分别为每个域名创建一个函数工作流。

    2. 单击“配置”，进入函数配置界面，修改常规设置。
      • 执行超时时间：函数运行的超时时间，超时的函数将被强行停止，建议设置为900。

        如果您发现转存的日志数量不对，请向“函数工作流”服务提工单，增大执行超时时间。

    3. 添加环境变量，在设置界面左侧单击“环境变量”。
      • url ：https://cdn.myhuaweicloud.com/v1.0/cdn/logs（CDN日志下载的url）。
      • domain_name ：example.com（需要转存日志的CDN加速域名）。
      • obsAddress ：***.obs.region.myhuaweicloud.com（用于存日志的OBS桶域名，region为OBS桶的region）。
      • destBucket ：cdnlog（用于存日志的OBS桶名称）。

      • 单击下方“保存”。
    4. 在设置界面左侧单击“权限”。
      • 选择已创建好的“FG_TO_CDN”委托，单击“保存”。
    5. 创建“触发器”。在函数配置界面单击“创建触发器”。
      • 触发器类型：定时触发器 (TIMER)。
      • 定时器名称：自定义的定时器名称，例如：Timer-0001。
      • 触发规则：Cron表达式。
      • Cron表达式：0 0 8 * * ?（每天早上8点执行一次日志转存储）。
      • 是否开启：开启。
    6. 单击“确定”，完成定时触发器设置。
    7. 创建测试事件。返回“代码”界面，单击“测试”按钮。
      • 配置测试事件：创建新的测试事件。
      • 事件模板：空白模板。
      • 事件名称：test。
      • 测试事件：{"message":"CDNLog-OBS"}。

      1. 单击“保存”，完成测试事件创建。
    8. 测试函数。在函数详情页面，单击左侧下拉框，选择“test”，单击“测试”。

  5. 查看配置是否成功
    1. 登录华为云控制台，在左侧导航栏，选择“存储>对象存储服务 OBS”。
    2. 单击您存储日志的桶（本实践为cdnlog），在左侧导航栏选择“对象”。
    3. 访问路径：文件夹（桶名称）>文件夹（加速域名）>文件夹（日志日期）>日志内容。

    • 当前代码示例仅支持转存当前时间前一日的日志，如果您需要转存日志的加速域名前一日没有日志产生，则OBS桶侧不会产生相关文件。
    • OBS桶将对转存到桶里的日志收费，具体收费规则请参考计费说明。
  6. 停止日志转存服务
    1. 登录华为云控制台，在左侧导航栏，选择“计算>函数工作流”，region选择“北京四”。
    2. 在左侧导航栏选择“函数”>“函数列表”，选中2中创建的函数名。
    3. 在函数详情页选择“触发器”。

    1. 单击“停用”，完成配置。

代码示例

代码如下所示：

# -*- coding:utf-8 -*-
import requests
import datetime
import time
import os
import sys
import json

from com.obs.client.obs_client import ObsClient

from urllib.parse import urlparse

if sys.version_info.major == 2 or not sys.version > '3':
    import httplib
else:
    import http.client as httplib

current_file_path = os.path.dirname(os.path.realpath(__file__))
# Adds the current path to search paths to import third-party libraries.
sys.path.append(current_file_path)

TEMP_ROOT_PATH = "/tmp/"  # Downloads a file from OBS to this directory.
region = 'china'  # This parameter does not need to be changed and will be used when FunctionGraph accesses OBS.
secure = True  # This parameter does not need to be changed and will be used when FunctionGraph accesses OBS.
signature = 'v4'  # This parameter does not need to be changed and will be used when FunctionGraph accesses OBS.
port = 443  # This parameter does not need to be changed and will be used when FunctionGraph accesses OBS.
path_style = True  # This parameter does not need to be changed and will be used when FunctionGraph accesses OBS.


def handler(event, context):
    logger = context.getLogger()
    queryDate = context.getUserData('queryDate')
    if queryDate is None:
        yesterday = datetime.date.today() + datetime.timedelta(-1)
        queryDate = yesterday.strftime("%Y-%m-%d")
        timeStamp = int(time.mktime(yesterday.timetuple()) * 1000)
    else:
        date = datetime.datetime.strptime(queryDate, "%Y-%m-%d")
        timeStamp = int(time.mktime(date.timetuple()) * 1000)

    pageSize = 20
    pageNumber = 1

    requests.packages.urllib3.disable_warnings()
    start(context, queryDate, timeStamp, pageSize, pageNumber)


def start(context, queryDate, timeStamp, pageSize, pageNumber):
    logger = context.getLogger()
    logUrl = context.getUserData('url')
    domainName = context.getUserData('domain_name')

    params = {'query_date': timeStamp, 'domain_name': domainName, 'page_size': pageSize, 'page_number': pageNumber, 'enterprise_project_id':'ALL'}
    headers = {'Content-Type': 'application/json;charset=UTF-8', 'X-Auth-Token': context.getToken()}
    res = requests.get(logUrl, params=params, headers=headers, verify=False)
    if res.status_code != 200:
        logger.info("query log urls: " + res.url + ", error: " + res.text)
        return ("query log urls: " + res.url + ", error: " + res.text)

    resJson = json.loads(res.text)
    logger.info(res.text)
    total = resJson['total']
    i = 0
    for val in resJson['logs']:
        i += 1
        logger.info(val["link"])

        url = urlparse(val["link"])
        netlocs = url.netloc.split(":")
        conn = httplib.HTTPConnection(netlocs[0], int(netlocs[1]))
        conn.request('GET', url.path + "?" + url.query)
        objName = os.path.join(val["domain_name"], queryDate, val["name"])
        put_content_to_obs(context, objName, conn.getresponse())

    if pageSize * pageNumber < total:
        start(context, queryDate, timeStamp, pageSize, pageNumber + 1)


def put_content_to_obs(context, objName, content):
    ak = context.getAccessKey()
    sk = context.getSecretKey()
    obsAddress = context.getUserData('obsAddress')
    destBucket = context.getUserData('destBucket')
    TestObs = ObsClient(access_key_id=ak, secret_access_key=sk,
                        is_secure=secure, server=obsAddress, signature=signature, path_style=path_style, region=region,
                        ssl_verify=False, port=port,
                        max_retry_count=5, timeout=20)
    resp = TestObs.putContent(destBucket, objName, content=content)
    if resp.status < 300:
        print('requestId:', resp.requestId)
    else:
        print('errorCode:', resp.errorCode)
        print('errorMessage:', resp.errorMessage)

相关文档