AWS CloudWatch Logs Handler for Monolog

This is a fork and continuation of the original maxbanton/cwh repository.

Handler for PHP logging library Monolog for sending log entries to AWS CloudWatch Logs service.

Before using this library, it's recommended to get acquainted with the pricing for AWS CloudWatch services.

Please press ★ Star button if you find this library useful.

Disclaimer

This library uses AWS API through AWS PHP SDK, which has limits on concurrent requests. It means that on high concurrent or high load applications it may not work on it's best way. Please consider using another solution such as logging to the stdout and redirecting logs with fluentd.

Requirements

• PHP >=8.1
• AWS account with proper permissions (see list of permissions below)

Features

• Up to 10000 batch logs sending in order to avoid Rate exceeded errors
• Log Groups creating with tags
• AWS CloudWatch Logs staff lazy loading
• Suitable for web applications and for long-living CLI daemons and workers
• New! Configurable rate limit, useful with small batch sizes on long-living CLI daemons and workers

Installation

Install the latest version with Composer by running

bash
1$ composer require phpnexus/cwh:^3.0

Basic Usage

php
1<?php
2
3use Aws\CloudWatchLogs\CloudWatchLogsClient;
4use Monolog\Logger;
5use Monolog\Level;
6use Monolog\Formatter\JsonFormatter;
7use PhpNexus\Cwh\Handler\CloudWatch;
8
9$sdkParams = [
10    'region' => 'eu-west-1',
11    'version' => 'latest',
12    'credentials' => [
13        'key' => 'your AWS key',
14        'secret' => 'your AWS secret',
15        'token' => 'your AWS session token', // token is optional
16    ]
17];
18
19// Instantiate AWS SDK CloudWatch Logs Client
20$client = new CloudWatchLogsClient($sdkParams);
21
22// Log group name, will be created if none
23$groupName = 'php-logtest';
24
25// Log stream name, will be created if none
26$streamName = 'ec2-instance-1';
27
28// Days to keep logs, 14 by default. Set to `null` to allow indefinite retention.
29$retentionDays = 30;
30
31// Instantiate handler (tags are optional)
32$handler = new CloudWatch($client, $groupName, $streamName, $retentionDays, 10000, ['my-awesome-tag' => 'tag-value'], Level::Info);
33
34// Optionally set the JsonFormatter to be able to access your log messages in a structured way
35$handler->setFormatter(new JsonFormatter());
36
37// Create a log channel
38$log = new Logger('name');
39
40// Set handler
41$log->pushHandler($handler);
42
43// Add records to the log
44$log->debug('Foo');
45$log->warning('Bar');
46$log->error('Baz');

Advanced Usage

Prevent automatic creation of log groups and streams

The default behavior is to check if the destination log group and log stream exists and create the log group and log stream if necessary.

This activity always sends a DescribeLogGroups and DescribeLogStreams API call to AWS, and will send a CreateLogGroup API call or CreateLogStream API call to AWS if the log group or log stream doesn't exist.

AWS have a default quota of 10 requests per second for DescribeLogGroups and 25 requests per second DescribeLogStreams per region per account, which will become a bottleneck even in medium traffic environments.

By setting $createGroup and $createStream to false, this library will not automatically create the destination log group or log stream, and hence will not send any DescribeLogGroups or DescribeLogStreams API calls to AWS.

php
1<?php
2
3use Aws\CloudWatchLogs\CloudWatchLogsClient;
4use Monolog\Logger;
5use Monolog\Level;
6use Monolog\Formatter\JsonFormatter;
7use PhpNexus\Cwh\Handler\CloudWatch;
8
9$sdkParams = [
10    'region' => 'ap-northeast-1',
11    'version' => 'latest',
12    'credentials' => [
13        'key' => 'your AWS key',
14        'secret' => 'your AWS secret',
15        'token' => 'your AWS session token', // token is optional
16    ]
17];
18
19// Instantiate AWS SDK CloudWatch Logs Client
20$client = new CloudWatchLogsClient($sdkParams);
21
22// Log group name (must exist already)
23$groupName = 'php-logtest';
24
25// Log stream name (must exist already)
26$streamName = 'ec2-instance-1';
27
28// Instantiate handler
29$handler = new CloudWatch($client, $groupName, $streamName, level: Level::Info, createGroup: false, createStream: false);
30
31// Optionally set the JsonFormatter to be able to access your log messages in a structured way
32$handler->setFormatter(new JsonFormatter());
33
34// Create a log channel
35$log = new Logger('name');
36
37// Set handler
38$log->pushHandler($handler);
39
40// Add records to the log
41$log->debug('Foo');
42$log->warning('Bar');
43$log->error('Baz');

New! Rate limiting

The default behavior is to send logs in batches of 10000, or when the script terminates. This is appropriate for short-lived requests, but not for long-lived CLI daemons and workers.

For these cases, a smaller $batchSize of 1 would be more appropriate. However, with a smaller batch size the number of putLogEvents requests to AWS will increase and may reach the per account per region limit.

To help avoid this rate limit, use the $rpsLimit option to limit the number of requests per second that your CLI daemon or worker can send.

Note: This limit is only applicable for one instance of a CLI daemon or worker. With multiple instances, adjust the $rpsLimit accordingly.

php
1<?php
2
3use Aws\CloudWatchLogs\CloudWatchLogsClient;
4use Monolog\Logger;
5use Monolog\Level;
6use Monolog\Formatter\JsonFormatter;
7use PhpNexus\Cwh\Handler\CloudWatch;
8
9$sdkParams = [
10    'region' => 'ap-northeast-1',
11    'version' => 'latest',
12    'credentials' => [
13        'key' => 'your AWS key',
14        'secret' => 'your AWS secret',
15        'token' => 'your AWS session token', // token is optional
16    ]
17];
18
19// Instantiate AWS SDK CloudWatch Logs Client
20$client = new CloudWatchLogsClient($sdkParams);
21
22// Log group name, will be created if none
23$groupName = 'php-logtest';
24
25// Log stream name, will be created if none
26$streamName = 'cli-worker';
27
28// Instantiate handler
29$handler = new CloudWatch($client, $groupName, $streamName, batchSize: 1, level: Level::Info, rpsLimit: 100);
30
31// Optionally set the JsonFormatter to be able to access your log messages in a structured way
32$handler->setFormatter(new JsonFormatter());
33
34// Create a log channel
35$log = new Logger('name');
36
37// Set handler
38$log->pushHandler($handler);
39
40// Add lots of records to the log very quickly
41$i = 0;
42do {
43    $log->info('Foo');
44} while ($i++ < 500);

Frameworks integration

• Silex
• Symfony (Example)
• Lumen
• Laravel (Example)

And many others

AWS IAM needed permissions

If you prefer to use a separate programmatic IAM user (recommended) or want to define a policy, you will need the following permissions depending on your configuration.

Always required:

1. PutLogEvents aws docs

If $createGroup is true (default):

1. DescribeLogGroups aws docs
2. CreateLogGroup aws docs
3. PutRetentionPolicy aws docs

If $createStream is true (default):

1. CreateLogStream aws docs
2. DescribeLogStreams aws docs

Note: The below samples include permissions to create log groups and streams. Remove the "AllowCreateLogGroup" statement when setting the $createGroup argument to false. Remove the "AllowCreateLogStream" statement when setting the $createStream argument to false.

Sample 1: Write to any log stream in any log group

This policy example allows writing to any log stream in a log group (named my-app). The log streams will be created automatically.

json
1{
2    "Version": "2012-10-17",
3    "Statement": [
4        {
5            "Sid": "AllowCreateLogGroup",
6            "Effect": "Allow",
7            "Action": [
8                "logs:CreateLogGroup",
9                "logs:DescribeLogGroups",
10                "logs:PutRetentionPolicy"
11            ],
12            "Resource": "arn:aws:logs:*:*:log-group:*"
13        },
14        {
15            "Sid": "AllowCreateLogStream",
16            "Effect": "Allow",
17            "Action": [
18                "logs:CreateLogStream",
19                "logs:DescribeLogStreams"
20            ],
21            "Resource": "arn:aws:logs:*:*:log-group:*:*"
22        },
23        {
24            "Sid": "AllowPutLogEvents",
25            "Effect": "Allow",
26            "Action": "logs:PutLogEvents",
27            "Resource": "arn:aws:logs:*:*:log-group:*:*"
28        }
29    ]
30}

Sample 2: Write to any log stream in a log group

This policy example allows writing to any log stream in a log group (named my-app). The log streams will be created automatically.

json
1{
2    "Version": "2012-10-17",
3    "Statement": [
4        {
5            "Sid": "AllowCreateLogGroup",
6            "Effect": "Allow",
7            "Action": [
8                "logs:CreateLogGroup",
9                "logs:DescribeLogGroups",
10                "logs:PutRetentionPolicy"
11            ],
12            "Resource": "arn:aws:logs:*:*:log-group:*"
13        },
14        {
15            "Sid": "AllowCreateLogStream",
16            "Effect": "Allow",
17            "Action": [
18                "logs:CreateLogStream",
19                "logs:DescribeLogStreams"
20            ],
21            "Resource": "arn:aws:logs:*:*:log-group:my-app:*"
22        },
23        {
24            "Sid": "AllowPutLogEvents",
25            "Effect": "Allow",
26            "Action": "logs:PutLogEvents",
27            "Resource": "arn:aws:logs:*:*:log-group:my-app:*"
28        }
29    ]
30}

Sample 3: Write to specific log streams in a log group

This policy example allows writing to specific log streams (named my-stream-1 and my-stream-2) in a log group (named my-app).

json
1{
2    "Version": "2012-10-17",
3    "Statement": [
4        {
5            "Sid": "AllowCreateLogGroup",
6            "Effect": "Allow",
7            "Action": [
8                "logs:CreateLogGroup",
9                "logs:DescribeLogGroups",
10                "logs:PutRetentionPolicy"
11            ],
12            "Resource": "arn:aws:logs:*:*:log-group:*"
13        },
14        {
15            "Sid": "AllowCreateLogStream",
16            "Effect": "Allow",
17            "Action": [
18                "logs:CreateLogStream",
19                "logs:DescribeLogStreams"
20            ],
21            "Resource": "arn:aws:logs:*:*:log-group:my-app:*"
22        },
23        {
24            "Sid": "AllowPutLogEvents",
25            "Effect": "Allow",
26            "Action": "logs:PutLogEvents",
27            "Resource": [
28                "arn:aws:logs:*:*:log-group:my-app:log-stream:my-stream-1",
29                "arn:aws:logs:*:*:log-group:my-app:log-stream:my-stream-2",
30            ]
31        }
32    ]
33}

Reference: Actions, resources, and condition keys for Amazon CloudWatch Logs

Issues

Feel free to report any issues

Contributing

Please check this document

---

Made in Ukraine 🇺🇦