Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
91 changes: 0 additions & 91 deletions README_CN.md
Original file line number Diff line number Diff line change
Expand Up @@ -975,97 +975,6 @@ res.log_print();

通过`delete_external_store`删除一个快速查询.



## 投递管理
投递的配置一般称为Job, 包含了投递的具体配置以及调度日程安排. 而某一个具体时间的运行实例称为Task.

- 获取配置列表

通过`list_shipper`获取投递配置的列表

- 创建配置

通过`create_shipper`创建一个投递配置. 可以传入一个json字符串(如下)或者对应的dict对象(如get_shipper获得的对象结果),如下:

OSS以CSV格式投递:
```json
{
"shipperName": "oss-ship-test1",
"targetConfiguration": {
"bufferInterval": 300,
"bufferSize": 256,
"compressType": "none",
"enable": true,
"ossBucket": "bucket1",
"ossPrefix": "bucket_folder1",
"pathFormat": "%Y/%m/%d/%H/%M",
"roleArn": "acs:ram::1234:role/aliyunlogdefaultrole",
"storage": {
"detail": {
"columns": [
"k3",
"k4"
],
"delimiter": "|",
"header": false,
"nullIdentifier": "",
"quote": "\""
},
"format": "csv"
}
},
"targetType": "oss"
}
```

OSS以JSON格式投递(注意storage.detail.columns为空是必须的,这个和get_shipper有所差别):
```json
{
"shipperName": "oss-ship-test1",
"targetConfiguration": {
"bufferInterval": 300,
"bufferSize": 256,
"compressType": "snappy",
"enable": true,
"ossBucket": "bucket1",
"ossPrefix": "bucket_folder1",
"pathFormat": "%Y/%m/%d/%H/%M",
"roleArn": "acs:ram::1234:role/aliyunlogdefaultrole",
"storage": {
"detail": {
"enableTag": true,
"columns": [
]
},
"format": "json"
}
},
"targetType": "oss"
}

```

- 获取配置

通过`get_shipper`获取一个投递配置的具体信息.

- 更新配置

通过`update_shipper`更新一个投递配置.

- 删除配置

通过`delete_shipper`删除一个投递配置.

- 获取运行实例列表

通过`get_shipper_tasks`获取投递运行实例.

- 重试运行实例

通过`retry_shipper_tasks`重试某一个运行实例.

## Elasticsearch 数据迁移
用于将 Elasticsearch 中的数据迁移至日志服务。

Expand Down
2 changes: 0 additions & 2 deletions aliyun/log/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@
from .logtail_config_detail import *
from .machine_group_detail import MachineGroupDetail
from .putlogsrequest import PutLogsRequest
from .shipper_config import ShipperTask, OssShipperConfig, OdpsShipperConfig
from .version import __version__
from .logitem import LogItem
from .consumer_group_request import *
Expand All @@ -30,7 +29,6 @@
from .project_response import *
from .pulllog_response import PullLogResponse
from .shard_response import *
from .shipper_response import *
from .common_response import *
from .external_store_config_response import *
from .proto import LogGroupRaw as LogGroup
Expand Down
Loading
Loading