提问者:小点点

PHP向Amazon SES发送大量电子邮件


我有一个在线软件,可以向亚马逊SES发送电子邮件。目前,我有一个cron作业,它使用phpmailer通过SMTP发送电子邮件来发送消息。目前,我必须将发送限制最大为每分钟300次,以确保我的服务器不会超时。我们看到增长,最终我想发送到10000或更多。

有没有更好的方法发送到亚马逊SES,或者这是其他人都做的,只是有更多的服务器运行工作负载?

提前感谢!


共3个答案

匿名用户

您可以尝试使用AWS SDK for PHP。您可以通过SES API发送电子邮件,SDK允许您并行发送多个电子邮件。下面是一个代码示例(未经测试,仅部分完成),可以帮助您入门。

<?php

require 'vendor/autoload.php';

use Aws\Ses\SesClient;
use Guzzle\Service\Exception\CommandTransferException;

$ses = SesClient::factory(/* ...credentials... */);

$emails = array();
// @TODO SOME SORT OF LOGIC THAT POPULATES THE ABOVE ARRAY

$emailBatch = new SplQueue();
$emailBatch->setIteratorMode(SplQueue::IT_MODE_DELETE);

while ($emails) {
    // Generate SendEmail commands to batch
    foreach ($emails as $email) {
        $emailCommand = $ses->getCommand('SendEmail', array(
            // GENERATE COMMAND PARAMS FROM THE $email DATA
        ));
        $emailBatch->enqueue($emailCommand);
    }

    try {
        // Send the batch
        $successfulCommands = $ses->execute(iterator_to_array($emailBatch));
    } catch (CommandTransferException $e) {
        $successfulCommands = $e->getSuccessfulCommands();
        // Requeue failed commands
        foreach ($e->getFailedCommands() as $failedCommand) {
            $emailBatch->enqueue($failedCommand);
        }
    }

    foreach ($successfulCommands as $command) {
        echo 'Sent message: ' . $command->getResult()->get('MessageId') . "\n";
    }
}

// Also Licensed under version 2.0 of the Apache License.

您还可以考虑使用GuzzleBatchBuilder和friends使其更加健壮。

使用此代码需要对很多事情进行微调,但您可能能够实现更高的电子邮件吞吐量。

匿名用户

如果有人在寻找这个答案,它已经过时了,您可以在这里找到新的文档:https://docs.aws.amazon.com/aws-sdk-php/v3/guide/guide/commands.html

use Aws\S3\S3Client;
use Aws\CommandPool;

// Create the client.
$client = new S3Client([
    'region'  => 'us-standard',
    'version' => '2006-03-01'
]);

$bucket = 'example';
$commands = [
    $client->getCommand('HeadObject', ['Bucket' => $bucket, 'Key' => 'a']),
    $client->getCommand('HeadObject', ['Bucket' => $bucket, 'Key' => 'b']),
    $client->getCommand('HeadObject', ['Bucket' => $bucket, 'Key' => 'c'])
];

$pool = new CommandPool($client, $commands);

// Initiate the pool transfers
$promise = $pool->promise();

// Force the pool to complete synchronously
$promise->wait();

对于SES命令可以做同样的事情

匿名用户

谢谢你的回答。这是一个很好的起点@杰里米·林德布洛姆

我的问题是现在我无法让错误处理工作。catch()-块在其内部工作正常

$successfulCommands

返回所有带有状态代码的成功响应,但仅在发生错误时返回。例如,沙盒模式中的“未验证地址”。就像一个catch()应该有用。:)

在try块中的$成功命令只返回:

SplQueue Object
(
    [flags:SplDoublyLinkedList:private] => 1
    [dllist:SplDoublyLinkedList:private] => Array
    (
    )
)

我不知道如何通过状态代码等从亚马逊获得真正的响应。