Skip to content

DataFlowProps

Properties for defining a DataFlow.

See https://www.alibabacloud.com/help/ros/developer-reference/aliyun-nas-dataflow

Initializer

import ros_cdk_nas
ros_cdk_nas.DataFlowProps(
  file_system_id: typing.Union[str, IResolvable],
  fset_id: typing.Union[str, IResolvable],
  source_storage: typing.Union[str, IResolvable],
  throughput: typing.Union[typing.Union[int, float], IResolvable],
  auto_refresh_interval: typing.Union[typing.Union[int, float], IResolvable] = None,
  auto_refresh_policy: typing.Union[str, IResolvable] = None,
  auto_refreshs: typing.Union[IResolvable, typing.List[typing.Union[IResolvable, AutoRefreshsProperty]]] = None,
  description: typing.Union[str, IResolvable] = None,
  source_security_type: typing.Union[str, IResolvable] = None
)

Properties

Name Type Description
file_system_id typing.Union[str, ros_cdk_core.IResolvable] Property fileSystemId: The ID of the file system.
fset_id typing.Union[str, ros_cdk_core.IResolvable] Property fsetId: The fileset ID.
source_storage typing.Union[str, ros_cdk_core.IResolvable] Property sourceStorage: The access path of the source storage.
throughput typing.Union[typing.Union[int, float], ros_cdk_core.IResolvable] Property throughput: The maximum data flow throughput.
auto_refresh_interval typing.Union[typing.Union[int, float], ros_cdk_core.IResolvable] Property autoRefreshInterval: The automatic update interval time, every time the interval, the CPFS checks whether there is a data update in the directory.
auto_refresh_policy typing.Union[str, ros_cdk_core.IResolvable] Property autoRefreshPolicy: The automatic update policy.
auto_refreshs typing.Union[ros_cdk_core.IResolvable, typing.List[typing.Union[ros_cdk_core.IResolvable, AutoRefreshsProperty]]] Property autoRefreshs:.
description typing.Union[str, ros_cdk_core.IResolvable] Property description: The description of the dataflow.
source_security_type typing.Union[str, ros_cdk_core.IResolvable] Property sourceSecurityType: The type of safety protection types of the source storage.

file_system_idRequired

file_system_id: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property fileSystemId: The ID of the file system.

  • The IDs of CPFS file systems must start with cpfs-. Example: cpfs-125487****.
  • The IDs of CPFS for Lingjun file systems must start with bmcpfs-. Example: bmcpfs-0015****.

fset_idRequired

fset_id: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property fsetId: The fileset ID.

This parameter is required for CPFS file systems.


source_storageRequired

source_storage: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property sourceStorage: The access path of the source storage.

Format: <storage type>:\/\/[<account id>:]<path>. Parameters:

  • storage type: Only OSS is supported.
  • account id (optional): the UID of the account of the source storage. This parameter is required when you use OSS buckets across accounts.
  • path: the name of the OSS bucket. Limits:
  • The name can contain only lowercase letters, digits, and hyphens (-). The name must start and end with a lowercase letter or digit.
  • The name can be up to 128 characters in length.
  • The name must be encoded in UTF-8.
  • The OSS bucket must be an existing bucket in the region.
  • Only CPFS for LINGJUN V2.6.0 and later support the account id parameter.

throughputRequired

throughput: typing.Union[typing.Union[int, float], IResolvable]
  • Type: typing.Union[typing.Union[int, float], ros_cdk_core.IResolvable]

Property throughput: The maximum data flow throughput.

Unit: MB/s. Valid values:

  • 600
  • 1200
  • 1500

The data flow throughput must be less than the I/O throughput of the file system. This parameter is required for CPFS file systems.


auto_refresh_intervalOptional

auto_refresh_interval: typing.Union[typing.Union[int, float], IResolvable]
  • Type: typing.Union[typing.Union[int, float], ros_cdk_core.IResolvable]

Property autoRefreshInterval: The automatic update interval time, every time the interval, the CPFS checks whether there is a data update in the directory.

If there is data update, start the automatic update task, unit: minute. Scope of value: 5 ~ 525600, default value: 10.


auto_refresh_policyOptional

auto_refresh_policy: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property autoRefreshPolicy: The automatic update policy.

The updated data in the source storage is imported into the CPFS file system based on the policy.

  • None (default): Updated data in the source storage is not automatically imported into the CPFS file system. You can run a data flow task to import the updated data from the source storage.
  • ImportChanged: Updated data in the source storage is automatically imported into the CPFS file system.

This parameter takes effect only for CPFS file systems.


auto_refreshsOptional

auto_refreshs: typing.Union[IResolvable, typing.List[typing.Union[IResolvable, AutoRefreshsProperty]]]
  • Type: typing.Union[ros_cdk_core.IResolvable, typing.List[typing.Union[ros_cdk_core.IResolvable, AutoRefreshsProperty]]]

Property autoRefreshs:.


descriptionOptional

description: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property description: The description of the dataflow.

Limits:

  • The description must be 2 to 128 characters in length.
  • The description must start with a letter but cannot start with http:\/\/ or https:\/\/.
  • The description can contain letters, digits, colons (:), underscores (_), and hyphens (-).

source_security_typeOptional

source_security_type: typing.Union[str, IResolvable]
  • Type: typing.Union[str, ros_cdk_core.IResolvable]

Property sourceSecurityType: The type of safety protection types of the source storage.

If the source storage must be protected through safety protection, please specify the type of safety protection type storage.Value: No (default value): It means that the source storage does not need to be accessed by safe protection. SSL: Protective access through SSL certificates.