要从SFTP服务器拉取数据到AWS中，可以使用AWS Transfer for SFTP服务和AWS Lambda函数来实现。以下是一个解决方案示例，包含了代码示例。

1. 创建SFTP服务器：

   • 登录AWS控制台，导航到AWS Transfer for SFTP服务。
   • 点击"创建服务器"按钮，按照向导创建一个SFTP服务器。在创建过程中，您需要指定身份提供者和身份提供者类型，以及S3存储桶作为后端存储。

2. 创建Lambda函数：

   • 登录AWS控制台，导航到Lambda服务。
   • 点击"创建函数"按钮，选择运行时环境和执行角色。
   • 将以下示例代码粘贴到Lambda函数的代码编辑器中：

import os
import boto3
from botocore.exceptions import NoCredentialsError

def lambda_handler(event, context):
    # 配置SFTP服务器参数
    sftp_host = 'sftp.example.com'
    sftp_port = 22
    sftp_username = 'your_username'
    sftp_password = 'your_password'

    # 配置S3存储桶参数
    s3_bucket = 'your_s3_bucket_name'
    s3_key = 'path/to/save/file.txt'

    # 创建SFTP客户端
    client = boto3.client('s3',
                          aws_access_key_id=os.environ['AWS_ACCESS_KEY'],
                          aws_secret_access_key=os.environ['AWS_SECRET_KEY'])

    # 从SFTP服务器拉取文件
    try:
        sftp = paramiko.SFTPClient.from_transport(
            paramiko.Transport((sftp_host, sftp_port)))
        sftp.connect(username=sftp_username, password=sftp_password)
        sftp.get('file.txt', '/tmp/file.txt')
        sftp.close()
    except Exception as e:
        print(str(e))
        return {
            'statusCode': 500,
            'body': str(e)
        }

    # 上传文件到S3存储桶
    try:
        client.upload_file('/tmp/file.txt', s3_bucket, s3_key)
    except FileNotFoundError:
        print("文件不存在")
        return {
            'statusCode': 404,
            'body': '文件不存在'
        }
    except NoCredentialsError:
        print("AWS凭证不存在")
        return {
            'statusCode': 500,
            'body': 'AWS凭证不存在'
        }

    return {
        'statusCode': 200,
        'body': '文件成功从SFTP服务器拉取并上传到S3存储桶'
    }

3. 配置Lambda函数触发器：
   • 在Lambda函数的配置页面中，点击"添加触发器"按钮。
   • 选择"CloudWatch Events"作为触发器类型，并配置定期触发器，以指定拉取数据的频率。

现在，当触发器触发Lambda函数时，它将连接到指定的SFTP服务器，下载文件并将其上传到指定的S3存储桶中。