# sls-php

**Repository Path**: talk-lucky/sls-php

## Basic Information

- **Project Name**: sls-php
- **Description**: The Aliyun SLS sdk for php.

- CreateConsumerGroup
- GetCheckPoint
- UpdateCheckPoint
- GetCursor
- HeartBeat
- PullLogs
- **Primary Language**: PHP
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2022-03-21
- **Last Updated**: 2022-06-08

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

## 项目简介

The Aliyun sls sdk.

## 安装

```bash
composer require "talk-lucky/sls"
```

## 文档

## 实现接口

- CreateConsumerGroup
- GetCheckPoint
- UpdateCheckPoint
- GetCursor
- HeartBeat
- PullLogs

### 初始化SLS客户端

```php
<?php

use SLS\Config;
use SLS\SLS;
use SLS\Events\ConsumerFailed;
use SLS\Events\ConsumeProcessed;
use SLS\Events\ConsumeProcessing;
use SLS\Consumer\ConsumerConfig;

// 配置
$config = new Config();
$config->setProtocol("https");
$config->setAccessKeyId("");
$config->setAccessKeySecret("");
$config->setRegionId("cn-shanghai");
$config->setEndpoint("cn-shanghai.log.aliyuncs.com");

// 实例化SLS客户端
$client = new SLS($config);
```

### 初始化consumer

```php
<?php
use SLS\Nil;
use SLS\Events\ConsumerFailed;
use SLS\Events\ConsumeProcessed;
use SLS\Events\ConsumeProcessing;
use SLS\Events\ConsumeInitCursor;
use SLS\Consumer\ConsumerConfig;

$consumerConfig = new ConsumerConfig();
$consumerConfig->setProtocol("https");
$consumerConfig->setAccessKeyId("");
$consumerConfig->setAccessKeySecret("");
$consumerConfig->setRegionId("cn-shanghai");
$consumerConfig->setEndpoint("cn-shanghai.log.aliyuncs.com");
$consumerConfig->setProject("");
$consumerConfig->setLogStore("");
$consumerConfig->setConsumerGroup("consumer-group");
$consumerConfig->setConsumer("consumer");
$consumerConfig->setEvents([
    ConsumeInitCursor::class => function(ConsumeInitCursor $cls) {},
    ConsumerFailed::class => new Nil,
    ConsumeProcessed::class => Nil::class,
    ConsumeProcessing::class => new class {
        public function handle(ConsumeProcessing $cls) {
        }  
    },
]);

// 实例化Consumer
$consumer = new Consumer($consumerConfig);
$consumer->run();
```