te')); return $arr; } /* 遍历用户所有主题 * @param $uid 用户ID * @param int $page 页数 * @param int $pagesize 每页记录条数 * @param bool $desc 排序方式 TRUE降序 FALSE升序 * @param string $key 返回的数组用那一列的值作为 key * @param array $col 查询哪些列 */ function thread_tid_find_by_uid($uid, $page = 1, $pagesize = 1000, $desc = TRUE, $key = 'tid', $col = array()) { if (empty($uid)) return array(); $orderby = TRUE == $desc ? -1 : 1; $arr = thread_tid__find($cond = array('uid' => $uid), array('tid' => $orderby), $page, $pagesize, $key, $col); return $arr; } // 遍历栏目下tid 支持数组 $fid = array(1,2,3) function thread_tid_find_by_fid($fid, $page = 1, $pagesize = 1000, $desc = TRUE) { if (empty($fid)) return array(); $orderby = TRUE == $desc ? -1 : 1; $arr = thread_tid__find($cond = array('fid' => $fid), array('tid' => $orderby), $page, $pagesize, 'tid', array('tid', 'verify_date')); return $arr; } function thread_tid_delete($tid) { if (empty($tid)) return FALSE; $r = thread_tid__delete(array('tid' => $tid)); return $r; } function thread_tid_count() { $n = thread_tid__count(); return $n; } // 统计用户主题数 大数量下严谨使用非主键统计 function thread_uid_count($uid) { $n = thread_tid__count(array('uid' => $uid)); return $n; } // 统计栏目主题数 大数量下严谨使用非主键统计 function thread_fid_count($fid) { $n = thread_tid__count(array('fid' => $fid)); return $n; } ?>amazon web services - Troubles reading CSV from S3 bucket to local machine - Stack Overflow
最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

amazon web services - Troubles reading CSV from S3 bucket to local machine - Stack Overflow

programmeradmin4浏览0评论

I'm have something testdataset.csv under the S3 bucket named testprojectbucket. Inside there is testdataset.csv

Here is what I've done:

  • I've granted access to my lambda function with AmazonS3ReadOnlyAccess

  • My lambda function has the basic lambda permissions

  • I've created an HTTP API via API gateway using the ANY method and integrated it with the lambda function

  • However, when I tried to invoke the API call in the machine it says Internal Server Error

I suspect it is my lambda function.

Here is my code:

import boto3
import csv
import io

s3 = boto3.client('s3')
bucket = 'testprojectbucket'
object_key = 'testdataset.csv'

def lambda_handler(event, context):
    try:
        # Get the object from S3
        response = s3.get_object(Bucket=bucket, Key=object_key)
        content = response['Body'].read().decode('utf-8')

        results = []
        
        # Parse CSV
        csv_reader = csv.DictReader(io.StringIO(content))
        for row in csv_reader:
            results.append(row)

        return {
            "statusCode": 200,
            "body": results
        }

    except Exception as e:
        return {
            "statusCode": 500,
            "error": str(e)
        }

Can anyone help? I am new to Cloud Computing in General.

发布评论

评论列表(0)

  1. 暂无评论