DescribeDataFlowTasks - Cloud Parallel File Storage - Alibaba Cloud Documentation Center

Mengkueri detail tugas alur kerja data.

Deskripsi operasi

Hanya CPFS versi 2.2.0 dan yang lebih baru serta CPFS for Lingjun versi 2.4.0 dan yang lebih baru yang mendukung pengkuerian tugas alur kerja data. Anda dapat melihat informasi versi pada halaman detail sistem file di Konsol.

Coba sekarang

Coba API ini di OpenAPI Explorer tanpa perlu penandatanganan manual. Panggilan yang berhasil akan secara otomatis menghasilkan contoh kode SDK sesuai dengan parameter Anda. Unduh kode tersebut dengan kredensial bawaan yang aman untuk penggunaan lokal.

Test

RAM authorization

Tabel berikut menjelaskan otorisasi yang diperlukan untuk memanggil API ini. Anda dapat menentukannya dalam kebijakan Resource Access Management (RAM). Kolom pada tabel dijelaskan sebagai berikut:

Action: Aksi yang dapat digunakan dalam elemen Action pada pernyataan kebijakan izin RAM untuk memberikan izin guna melakukan operasi tersebut.
API: API yang dapat Anda panggil untuk melakukan aksi tersebut.
Access level: Tingkat akses yang telah ditentukan untuk setiap API. Nilai yang valid: create, list, get, update, dan delete.
Resource type: Jenis resource yang mendukung otorisasi untuk melakukan aksi tersebut. Ini menunjukkan apakah aksi tersebut mendukung izin tingkat resource. Resource yang ditentukan harus kompatibel dengan aksi tersebut. Jika tidak, kebijakan tersebut tidak akan berlaku.
- Untuk API dengan izin tingkat resource, jenis resource yang diperlukan ditandai dengan tanda bintang (*). Tentukan Nama Sumber Daya Alibaba Cloud (ARN) yang sesuai dalam elemen Resource pada kebijakan.
- Untuk API tanpa izin tingkat resource, ditampilkan sebagai All Resources. Gunakan tanda bintang (*) dalam elemen Resource pada kebijakan.
Condition key: Kunci kondisi yang didefinisikan oleh layanan. Kunci ini memungkinkan kontrol granular, berlaku baik hanya untuk aksi maupun untuk aksi yang terkait dengan resource tertentu. Selain kunci kondisi spesifik layanan, Alibaba Cloud menyediakan serangkaian common condition keys yang berlaku di semua layanan yang didukung RAM.
Dependent action: Aksi dependen yang diperlukan untuk menjalankan aksi tersebut. Untuk menyelesaikan aksi tersebut, pengguna RAM atau role RAM harus memiliki izin untuk melakukan semua aksi dependen.

Action

Access level

Resource type

Condition key

Dependent action

nas:DescribeDataFlowTasks

get

*DataFlow

acs:nas:{#regionId}:{#accountId}:filesystem/{#filesystemId}

None

Parameter permintaan

Parameter	Type	Required	Description	Example
FileSystemId	string	Yes	ID sistem file. CPFS umum: harus dimulai dengan `cpfs-`, misalnya cpfs-099394bd928c**. CPFS for Lingjun: harus dimulai dengan `bmcpfs-`, misalnya bmcpfs-290w65p03ok64ya**.	bmcpfs-290w65p03ok64ya****
Filters	array<object>	No	Kondisi filter.
	object	No
Key	string	No	Nama kunci filter. Nilai valid: DataFlowIds: memfilter berdasarkan ID alur kerja data. TaskIds: memfilter berdasarkan ID tugas alur kerja data. Originator: memfilter berdasarkan penginisiasi tugas alur kerja data. TaskActions: memfilter berdasarkan jenis tugas alur kerja data. DataTypes: memfilter berdasarkan tipe data tugas alur kerja data. Status: memfilter berdasarkan status alur kerja data. CreateTimeBegin: memfilter tugas alur kerja data yang dibuat setelah waktu tertentu. CreateTimeEnd: memfilter tugas alur kerja data yang dibuat sebelum waktu tertentu. StartTimeBegin: memfilter tugas alur kerja data yang dimulai setelah waktu tertentu. StartTimeEnd: memfilter tugas alur kerja data yang dimulai sebelum waktu tertentu. EndTimeBegin: memfilter tugas alur kerja data yang berakhir setelah waktu tertentu. EndTimeEnd: memfilter tugas alur kerja data yang berakhir sebelum waktu tertentu. Valid values: Status : memfilter berdasarkan status alur kerja data. TaskIds : memfilter berdasarkan ID tugas alur kerja data. Originator : memfilter berdasarkan penginisiasi tugas alur kerja data. CreateTimeEnd : memfilter tugas alur kerja data yang dibuat sebelum waktu tertentu. EndTimeBegin : memfilter tugas alur kerja data yang berakhir setelah waktu tertentu. DataFlowIds : memfilter berdasarkan ID alur kerja data. StartTimeEnd : memfilter tugas alur kerja data yang dimulai sebelum waktu tertentu. TaskActions : memfilter berdasarkan jenis tugas alur kerja data. EndTimeEnd : memfilter tugas alur kerja data yang berakhir sebelum waktu tertentu. StartTimeBegin : memfilter tugas alur kerja data yang dimulai setelah waktu tertentu. CreateTimeBegin : memfilter tugas alur kerja data yang dibuat setelah waktu tertentu. DataTypes : memfilter berdasarkan tipe data tugas alur kerja data.	DataFlowIds.
Value	string	No	Nilai kunci filter. Wildcard tidak didukung. Jika Key diatur ke DataFlowIds, Value diatur ke ID alur kerja data atau sebagian dari ID alur kerja data. Anda dapat menentukan satu atau beberapa ID alur kerja data. Maksimal 10 ID alur kerja data dapat ditentukan. Contoh: `df-194433a5be31**` atau `df-194433a512a2,df-234533a5be31`. Jika Key diatur ke TaskId, Value diatur ke ID tugas alur kerja data atau sebagian dari ID tugas alur kerja data. Anda dapat menentukan satu atau beberapa ID tugas alur kerja data. Maksimal 10 ID tugas alur kerja data dapat ditentukan. Contoh: `task-38aa8e890f45` atau `task-38aa8e890f45,task-29ae8e890f45`. Jika Key diatur ke TaskActions, Value diatur ke jenis tugas alur kerja data, termasuk Import, Export, Evict, Inventory, StreamImport, dan StreamExport**. Kueri gabungan didukung. CPFS for Lingjun hanya mendukung Import, Export, StreamImport, dan StreamExport. StreamImport dan StreamExport hanya didukung oleh CPFS for Lingjun versi 2.6.0 dan yang lebih baru. Jika Key diatur ke DataTypes, Value diatur ke tipe data tugas alur kerja data, termasuk MetaAndData, Metadata, dan Data. Kueri gabungan didukung. Jika Key diatur ke Originator, Value diatur ke penginisiasi tugas alur kerja data, termasuk User dan System. Jika Key diatur ke Status, Value diatur ke status tugas alur kerja data, termasuk Pending, Executing, Failed, Completed, Canceling, dan Canceled. Kueri gabungan didukung. Jika Key diatur ke CreateTimeBegin, Value diatur ke waktu pembuatan paling awal dari tugas alur kerja data. Format: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke CreateTimeEnd, Value diatur ke waktu pembuatan paling akhir dari tugas alur kerja data. Format: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke StartTimeBegin, Value diatur ke waktu mulai paling awal dari tugas alur kerja data. Format: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke StartTimeEnd, Value diatur ke waktu mulai paling akhir dari tugas alur kerja data. Format: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke EndTimeBegin, Value diatur ke waktu berakhir paling awal dari tugas alur kerja data. Format: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke EndTimeEnd, Value diatur ke waktu berakhir paling akhir dari tugas alur kerja data. Format: `yyyy-MM-ddThh:mmZ`.	df-194433a5be31****
NextToken	string	No	Token paginasi yang digunakan dalam permintaan berikutnya untuk mengambil halaman hasil baru. Jika hasil yang dikembalikan terpotong, Anda dapat menggunakan NextToken untuk memulai permintaan baru guna mengambil konten setelah posisi pemotongan saat ini.	TGlzdFJlc291cmNlU****mVzJjE1MTI2NjY4NzY5MTAzOTEmMiZORnI4NDhVeEtrUT0=
MaxResults	integer	No	Jumlah hasil untuk setiap kueri. Nilai valid: 10 hingga 100. Nilai default: 20.	20
WithReports	boolean	No	Apakah akan mengkueri informasi laporan. True (default): mengkueri laporan. False: tidak mengkueri laporan. Catatan Mengatur parameter ini ke False dapat mempercepat kueri. Hanya didukung oleh CPFS for Lingjun.	True.

Elemen respons

Element	Type	Description	Example
	object
RequestId	string	ID permintaan.	2D69A58F-345C-4FDE-88E4-BF518948****
NextToken	string	Token paginasi yang digunakan dalam permintaan berikutnya untuk mengambil halaman hasil baru. Jika hasil yang dikembalikan terpotong, Anda dapat menggunakan NextToken untuk memulai permintaan baru guna mengambil konten setelah posisi pemotongan saat ini.	TGlzdFJlc291cmNlU****mVzJjE1MTI2NjY4NzY5MTAzOTEmMiZORnI4NDhVeEtrUT0=
TaskInfo	object
Task	array<object>	Informasi tentang tugas alur kerja data.
	array<object>
FilesystemId	string	ID sistem file.	bmcpfs-290w65p03ok64ya****
DataFlowId	string	ID alur kerja data.	df-194433a5be31****
TaskId	string	ID tugas alur kerja data.	task-38aa8e890f45****
SourceStorage	string	Jalur akses penyimpanan sumber. Format: `<storage type>://[<account id>:]<path>`. Di mana: storage type: hanya oss yang didukung. account id: UID akun yang memiliki penyimpanan sumber. path: nama Bucket OSS. Batasan: Hanya huruf kecil, angka, dan tanda hubung (-) yang didukung. Nama harus dimulai dan diakhiri dengan huruf kecil atau angka. Panjang maksimal adalah 128 karakter. Pengkodean UTF-8 digunakan. Catatan Bucket OSS harus sudah ada di wilayah tersebut. Parameter account id hanya didukung oleh CPFS for Lingjun 2.6.0 dan versi lebih baru.	oss://178321033379****:bucket-01
FileSystemPath	string	Jalur fileset dalam sistem file CPFS. Batasan: Panjangnya 2 hingga 1.024 karakter. Pengkodean UTF-8 digunakan. Jalur harus dimulai dan diakhiri dengan garis miring (/). Direktori harus berupa direktori fileset pada CPFS. Catatan Hanya CPFS yang mendukung parameter ini.	/a/b/c/
Originator	string	Penginisiasi tugas alur kerja data. Nilai valid: User: tugas diinisiasi oleh pengguna. System: tugas merupakan tugas pembaruan otomatis yang diinisiasi oleh CPFS berdasarkan interval pembaruan otomatis. Catatan Hanya CPFS yang mendukung parameter ini.	User.
TaskAction	string	Jenis node alur kerja data. Nilai valid: Import: melakukan impor data dari penyimpanan sumber ke CPFS. Export: mengekspor data tertentu dari CPFS ke penyimpanan sumber. StreamImport: melakukan impor data dari penyimpanan sumber ke CPFS sebagai node aliran data. StreamExport: mengekspor data tertentu dari CPFS ke penyimpanan sumber sebagai node aliran data. Evict: merilis blok data file di CPFS. Setelah pelepasan, hanya metadata yang dipertahankan di CPFS. Anda masih dapat mengkueri file, tetapi blok data dibersihkan dan tidak menempati kapasitas penyimpanan di CPFS. Saat data file diakses, data dimuat dari penyimpanan sumber sesuai kebutuhan. Inventory: memperoleh daftar periksa file yang dikelola oleh alur kerja data di CPFS, yang menyediakan status cache file dalam alur kerja data. Catatan StreamImport dan StreamExport hanya didukung oleh CPFS for Lingjun 2.6.0 dan versi lebih baru.	Import.
DataType	string	Tipe data tugas alur kerja data. Nilai valid: Metadata: metadata file, termasuk stempel waktu, kepemilikan, izin, dan atribut lainnya. Jika Metadata dipilih, hanya metadata file yang diimpor. Pengguna dapat melihat file, tetapi saat data file diakses, data dimuat dari penyimpanan sumber sesuai kebutuhan. Data: blok data file. MetaAndData: metadata dan blok data file. Catatan CPFS for Lingjun hanya mendukung tipe MetaAndData.	MetaAndData.
Progress	integer	Progres tugas alur kerja data. Jumlah operasi yang telah dilakukan oleh tugas alur kerja data saat ini.	50
Status	string	Status tugas alur kerja data. Nilai valid: Pending: tugas alur kerja data dibuat dan masuk antrean tetapi belum dimulai. Executing: tugas alur kerja data sedang dieksekusi. Failed: tugas alur kerja data gagal. Anda dapat melihat laporan tugas alur kerja data untuk alasan kegagalan. Completed: tugas alur kerja data selesai. Anda dapat melihat laporan tugas alur kerja data untuk memverifikasi bahwa semua file ditransfer dengan benar. Canceled: tugas alur kerja data dibatalkan dan tidak selesai. Canceling: tugas alur kerja data sedang dibatalkan.	Failed.
ReportPath `deprecated`	string	Jalur tempat laporan tugas alur kerja data disimpan dalam sistem file CPFS. Untuk CPFS, laporan tugas dihasilkan di direktori `.dataflow_report` dari sistem file CPFS. Untuk CPFS for Lingjun, tautan unduhan OSS dikembalikan. Anda dapat menggunakan tautan tersebut untuk mengunduh laporan tugas.	/path_in_cpfs/reportfile.cvs.
CreateTime	string	Waktu ketika tugas dibuat. Waktu mengikuti standar ISO 8601. Format: yyyy-MM-dd HH:mm:ss.	2021-08-04 18:27:35
StartTime	string	Waktu ketika tugas dimulai. Waktu mengikuti standar ISO 8601. Format: yyyy-MM-dd HH:mm:ss.	2021-08-04 18:27:35
EndTime	string	Waktu ketika tugas berakhir. Waktu mengikuti standar ISO 8601. Format: yyyy-MM-dd HH:mm:ss.	2021-08-04 18:27:35
FsPath	string	Jalur direktori cerdas.	/aa/
ConflictPolicy	string	Kebijakan konflik untuk file dengan nama yang sama. SKIP_THE_FILE: melewatkan file dengan nama yang sama. KEEP_LATEST: membandingkan waktu pembaruan dan menyimpan versi terbaru. OVERWRITE_EXISTING: menimpa paksa file dengan nama yang sama. Valid values: KEEP_LATEST : Membandingkan waktu pembaruan dan menyimpan versi terbaru. OVERWRITE_EXISTING : Menimpa paksa file dengan nama yang sama. SKIP_THE_FILE : Melewatkan file dengan nama yang sama.	KEEP_LATEST.
Directory	string	Direktori tempat tugas alur kerja data dieksekusi.	/path_in_cpfs/
DstDirectory	string	Direktori tujuan tempat tugas alur kerja data dipetakan.	/path_in_cpfs/
ErrorMsg	string	Pesan error tugas. Catatan Jika bidang ini tidak dikembalikan atau kosong, tidak terjadi error.	{"ErrorKey":"PATH_NOT_ACCESSIBLE","ErrorDetail":"lstat /cpfs/370lx1ev9ss27o****/test/abcdfnotfound: no such file or directory"}
ProgressStats	object	Informasi progres tugas alur kerja data.
FilesTotal	integer	Jumlah total file yang discan di sumber.	3
FilesDone	integer	Jumlah file yang alur kerja datanya selesai, termasuk file yang dilewati.	3
ActualFiles	integer	Jumlah aktual file yang ditransfer.	3
BytesTotal	integer	Jumlah total data yang discan di sumber. Unit: byte.	131092971520
BytesDone	integer	Jumlah data yang alur kerja datanya selesai, termasuk data yang dilewati. Unit: byte.	131092971520
ActualBytes	integer	Jumlah aktual data yang ditransfer. Unit: byte.	131092971520
RemainTime	integer	Perkiraan sisa waktu. Unit: detik.	437
AverageSpeed	integer	Kecepatan transfer rata-rata. Unit: byte per detik.	342279299
Reports	object
Report	array<object>	Daftar laporan. Catatan Tugas streaming tidak mendukung laporan. Jika WithReport diatur ke True, parameter ini mengembalikan data laporan untuk CPFS for Lingjun. Hanya CPFS for Lingjun yang mendukung parameter WithReport.
	object
Name	string	Nama laporan. CPFS: TotalFilesReport: laporan tugas. CPFS for Lingjun: FailedFilesReport: laporan file yang gagal. SkippedFilesReport: laporan file yang dilewati. SuccessFilesReport: laporan file yang berhasil.	TotalFilesReport.
Path	string	Tautan laporan.	https://a-hbr-temp-cn-hangzhou-staging.oss-cn-hangzhou.aliyuncs.com/temp/report/162319438359**/job-000bb6fwqficjbxk/job-000bb6fwqficjbxk_failed.zip?Expires=1721201422&OSSAccessKeyId=LTA**************&Signature=Fp%2BvauORTIVxooXY2tec6z0T%2Bp4%3D.
Includes	string	Direktori yang difilter di bawah direktori. Konten dari direktori yang difilter ditransfer. Catatan Hanya CPFS for Lingjun yang mendukung fitur ini.	["/test/","/test1/"]
TransferFileListPath	string	Direktori OSS yang ditentukan. Data disinkronkan berdasarkan konten file CSV di direktori OSS. Catatan Hanya CPFS for Lingjun yang mendukung fitur ini.	/path_in_cpfs/
EntryList	string

Contoh

Respons sukses

JSONformat

{
  "RequestId": "2D69A58F-345C-4FDE-88E4-BF518948****",
  "NextToken": "TGlzdFJlc291cmNlU****mVzJjE1MTI2NjY4NzY5MTAzOTEmMiZORnI4NDhVeEtrUT0=",
  "TaskInfo": {
    "Task": [
      {
        "FilesystemId": "bmcpfs-290w65p03ok64ya****",
        "DataFlowId": "df-194433a5be31****",
        "TaskId": "task-38aa8e890f45****",
        "SourceStorage": "oss://178321033379****:bucket-01",
        "FileSystemPath": "/a/b/c/",
        "Originator": "User.",
        "TaskAction": "Import.",
        "DataType": "MetaAndData.",
        "Progress": 50,
        "Status": "Failed.",
        "ReportPath": "/path_in_cpfs/reportfile.cvs.",
        "CreateTime": "2021-08-04 18:27:35",
        "StartTime": "2021-08-04 18:27:35",
        "EndTime": "2021-08-04 18:27:35",
        "FsPath": "/aa/",
        "ConflictPolicy": "KEEP_LATEST.",
        "Directory": "/path_in_cpfs/",
        "DstDirectory": "/path_in_cpfs/",
        "ErrorMsg": "{\"ErrorKey\":\"PATH_NOT_ACCESSIBLE\",\"ErrorDetail\":\"lstat /cpfs/370lx1ev9ss27o****/test/abcdfnotfound: no such file or directory\"}",
        "ProgressStats": {
          "FilesTotal": 3,
          "FilesDone": 3,
          "ActualFiles": 3,
          "BytesTotal": 131092971520,
          "BytesDone": 131092971520,
          "ActualBytes": 131092971520,
          "RemainTime": 437,
          "AverageSpeed": 342279299
        },
        "Reports": {
          "Report": [
            {
              "Name": "TotalFilesReport.",
              "Path": "https://a-hbr-temp-cn-hangzhou-staging.oss-cn-hangzhou.aliyuncs.com/temp/report/162319438359****/job-000bb6fwqficjbxk****/job-000bb6fwqficjbxk****_failed.zip?Expires=1721201422&OSSAccessKeyId=LTA****************&Signature=Fp%2BvauORTIVxooXY2tec6z0T%2Bp4%3D."
            }
          ]
        },
        "Includes": "[\"/test/\",\"/test1/\"]",
        "TransferFileListPath": "/path_in_cpfs/",
        "EntryList": ""
      }
    ]
  }
}

Kode kesalahan

HTTP status code	Error code	Error message	Description
400	IllegalCharacters	The parameter contains illegal characters.	Parameter tidak valid.
400	MissingFileSystemId	FileSystemId is mandatory for this action.	Parameter FileSystemId tidak ditentukan.
400	InvalidFilesystemVersion.NotSupport	This Api does not support this fileSystem version.	Operasi saat ini tidak mendukung versi sistem file ini.
403	OperationDenied.DataFlowNotSupported	The operation is not supported.	Sistem file tidak mendukung dataflow.
404	InvalidParameter.InvalidNextToken	The specified NextToken is invaild.
404	InvalidFileSystem.NotFound	The specified file system does not exist.	Sistem file yang ditentukan tidak ada.
404	InvalidDataFlow.NotFound	The specified data flow does not exist.	Alur data yang ditentukan tidak ada.
404	InvalidParameter.InvalidMaxResults	The specified MaxResults is invalid.	MaxResults yang ditentukan tidak valid.
404	InvalidFilterParam	The specified Filter.N.Key is invalid.	Parameter Filter.N.Key yang ditentukan tidak valid.

Lihat Error Codes untuk daftar lengkap.

Catatan rilis

Lihat Release Notes untuk daftar lengkap.