编写函数

编写函数代码（Python）

1. 登录函数计算控制台。
2. 在顶部菜单栏，选择地域。
3. 在左侧导航栏，单击服务-函数。
4. 找到目标服务下的目标函数，单击函数名称。
   
5. 单击代码执行页签，在代码编辑器中编写代码。
   本文以 Python 函数代码为例。以下示例代码可以作为提取大部分逻辑日志的模板。其中 accessKeyId 和 accessKey 可以填写在代码内，也可以从 context 和 creds 中获取。

   # -*- coding: utf-8 -*-
   import logging
   import json
   from aliyun.log import LogClient
   from time import time
   
   def logClient(endpoint, creds):
     logger = logging.getLogger()
     logger.info('creds info')
     logger.info(creds.access_key_id)
     logger.info(creds.access_key_secret)
     logger.info(creds.security_token)
     accessKeyId = 'your accessKeyId'
     accessKey = 'your accessKeyId scr'
     client = LogClient(endpoint, accessKeyId, accessKey)
     return client
   
   def handler(event, context):
     logger = logging.getLogger()
     logger.info('start deal SLS data')
     logger.info(event.decode().encode())
     info_arr = json.loads(event.decode())
     fetchdata(info_arr['source'],context)
     return 'hello world'
   
    def fetchdata(event,context):
     logger = logging.getLogger()
     endpoint = event['endpoint']
     creds = context.credentials
     client = logClient(endpoint, creds)
     if client == None :
         logger.info("client creat failed")
         return False
     project = event['projectName']
     logstore = event['logstoreName']
     start_cursor = event['beginCursor']
     end_cursor = event['endCursor']
     loggroup_count = 10
     shard_id = event['shardId']
     while True:
         res = client.pull_logs(project, logstore, shard_id, start_cursor, loggroup_count, end_cursor)
         res.log_print()
         next_cursor = res.get_next_cursor()
         if next_cursor == start_cursor :
             break
         start_cursor = next_cursor
   
       #log_data =  res.get_loggroup_json_list()
     return True                        

event 格式说明

event 是函数计算的入口参数。具体格式为如下。

{
    "parameter": {},
    "source": {
        "endpoint": "http://cn-shanghai-intranet.log.aliyuncs.com",
        "projectName": "log-com",
        "logstoreName": "log-en",
        "shardId": 0,
        "beginCursor": "MTUyOTQ4MDIwOTY1NTk3ODQ2Mw==",
        "endCursor": "MTUyOTQ4MDIwOTY1NTk3ODQ2NA=="
    },
    "jobName": "1f7043ced683de1a4e3d8d70b5a412843d817a39",
    "taskId": "c2691505-38da-4d1b-998a-f1d4bb8c9994",
    "cursorTime": 1529486425
}