Reviewed-by: Kacur, Michal <michal.kacur@t-systems.com> Co-authored-by: chenxiaoxiong <chenxiaoxiong@huawei.com> Co-committed-by: chenxiaoxiong <chenxiaoxiong@huawei.com>
28 KiB
Querying Details of a Stream
Function
This API is used to query details about a specified stream.
Calling Method
For details, see Calling APIs.
URI
GET /v2/{project_id}/streams/{stream_name}
Parameter |
Mandatory |
Type |
Description |
|---|---|---|---|
project_id |
Yes |
String |
Project ID |
stream_name |
Yes |
String |
Name of the stream to be queried Maximum: 60 |
Parameter |
Mandatory |
Type |
Description |
|---|---|---|---|
start_partitionId |
No |
String |
Name of the partition to start the partition list with. The returned partition list does not contain this partition. |
limit_partitions |
No |
Integer |
Max. number of partitions to list in a single API call. Minimum: 1 Maximum: 1000 Default: 100 |
Request Parameters
Parameter |
Mandatory |
Type |
Description |
|---|---|---|---|
X-Auth-Token |
Yes |
String |
User token. It can be obtained by calling the IAM API used to obtain a user token. The value of X-Subject-Token in the response header is the user token. |
Response Parameters
Status code: 200
Parameter |
Type |
Description |
|---|---|---|
stream_name |
String |
Stream name |
create_time |
Long |
Time when the stream is created. The value is a 13-bit timestamp. |
last_modified_time |
Long |
Time when a stream is the most recently modified. The value is a 13-bit timestamp. |
status |
String |
Current status of the stream.
Enumeration values:
|
stream_type |
String |
Stream type
Enumeration values:
|
partitions |
Array of PartitionResult objects |
Partition list of the stream |
has_more_partitions |
Boolean |
Whether there are more matching partitions.
|
retention_period |
Integer |
Period for storing data in units of hours |
stream_id |
String |
Unique identifier of the stream |
data_type |
String |
Source data type.
Default value: BLOB Enumeration values:
|
data_schema |
String |
Source data structure that defines JSON and CSV formats. It is described in the syntax of the Avro schema. For details about Avro, go to http://avro.apache.org/docs/current/#schemas. |
compression_format |
String |
Data compression type. Currently, the following compression types are supported:
By default, data is not compressed. Enumeration values:
|
csv_properties |
CSVProperties object |
Attributes of data in CSV format, such as delimiter |
writable_partition_count |
Integer |
Total number of writable partitions (including partitions in ACTIVE state only) |
readable_partition_count |
Integer |
Total number of readable partitions (including partitions in ACTIVE and DELETED state). |
update_partition_counts |
Array of UpdatePartitionCount objects |
List of scaling operation records |
tags |
Array of Tag objects |
List of stream tags |
sys_tags |
Array of SysTag objects |
Enterprise project of a stream |
auto_scale_enabled |
Boolean |
Whether to enable auto scaling.
By default, auto scaling is disabled. |
auto_scale_min_partition_count |
Integer |
Minimum number of partitions for automatic scale-down when auto scaling is enabled. |
auto_scale_max_partition_count |
Integer |
Maximum number of partitions for automatic scale-up when auto scaling is enabled. |
Parameter |
Type |
Description |
|---|---|---|
status |
String |
Current status of the partition
Enumeration values:
|
partition_id |
String |
Unique identifier of the partition |
hash_range |
String |
Possible value range of the hash key used by the partition |
sequence_number_range |
String |
Sequence number range of the partition |
parent_partitions |
String |
Parent partition |
Parameter |
Type |
Description |
|---|---|---|
create_timestamp |
Long |
Scaling execution timestamp, which is a 13-digit timestamp. |
src_partition_count |
Integer |
Number of partitions before scaling |
target_partition_count |
Integer |
Number of partitions after scaling |
result_code |
Integer |
Response code of the scaling operation |
result_msg |
Integer |
Response to the scaling operation |
auto_scale |
Boolean |
Whether the scaling operation is automatic
|
Parameter |
Type |
Description |
|---|---|---|
key |
String |
Tag key.
Minimum: 1 Maximum: 36 |
value |
String |
Value.
Minimum: 0 Maximum: 43 |
Parameter |
Type |
Description |
|---|---|---|
key |
String |
Tag key.
|
status |
String |
Enumeration values:
|
value |
String |
Value. The value is the enterprise project ID, which needs to be obtained on the enterprise management page.
|
Example Requests
Querying Details of a Stream
GET https://{Endpoint}/v2/{project_id}/streams/{stream_name}
Example Responses
Status code: 200
Normal response
{
"stream_id" : "8QM3Nt9YTLOwtUVYJhO",
"stream_name" : "newstream",
"create_time" : 1593569685875,
"last_modified_time" : "1599050091026,",
"retention_period" : 24,
"status" : "RUNNING",
"stream_type" : "COMMON",
"data_type" : "BLOB",
"writable_partition_count" : 1,
"readable_partition_count" : 1,
"tags" : [ ],
"auto_scale_enabled" : false,
"auto_scale_min_partition_count" : 0,
"auto_scale_max_partition_count" : 0,
"partitions" : [ {
"status" : "ACTIVE",
"partition_id" : "shardId-0000000000",
"hash_range" : "[0 : 9223372036854775807]",
"sequence_number_range" : "[289911 : 289927]"
} ],
"has_more_partitions" : false
}
Status Codes
Status Code |
Description |
|---|---|
200 |
Normal response |
Error Codes
See Error Codes.