DescribeDataFlowTasks - Cloud Parallel File Storage - Alibaba Cloud Documentation Center

Menanyakan detail tugas alur data.

Deskripsi operasi

Hanya CPFS versi 2.2.0 ke atas dan CPFS for Lingjun versi 2.4.0 ke atas yang mendukung kueri tugas alur data. Informasi versi dapat dilihat 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

Tidak ada otorisasi untuk operasi ini. Jika Anda mengalami masalah saat menjalankan operasi ini, hubungi dukungan teknis.

Parameter permintaan

Parameter	Type	Required	Description	Example
FileSystemId	string	Yes	ID sistem file. ID sistem file CPFS harus diawali dengan `cpfs-`. Contoh: cpfs-099394bd928c**. ID sistem file CPFS for Lingjun harus diawali dengan `bmcpfs-`. Contoh: bmcpfs-290w65p03ok64ya**.	bmcpfs-290w65p03ok64ya****
Filters	array<object>	No	Detail filter.
	object	No
Key	string	No	Nama filter. Nilai yang valid: DataFlowIds: memfilter tugas alur data berdasarkan ID alur data. TaskIds: memfilter tugas alur data berdasarkan ID tugas. Originator: memfilter tugas alur data berdasarkan inisiator tugas. TaskActions: memfilter tugas alur data berdasarkan jenis tugas. DataTypes: memfilter tugas alur data berdasarkan tipe data. Status: memfilter tugas alur data berdasarkan status alur data. CreateTimeBegin: memfilter tugas alur data yang dibuat setelah waktu tertentu. CreateTimeEnd: memfilter tugas alur data yang dibuat sebelum waktu tertentu. StartTimeBegin: memfilter tugas alur data yang dimulai setelah waktu tertentu. StartTimeEnd: memfilter tugas alur data yang dimulai sebelum waktu tertentu. EndTimeBegin: memfilter tugas alur data yang dihentikan setelah waktu tertentu. EndTimeEnd: memfilter tugas alur data yang dihentikan sebelum waktu tertentu.	DataFlowIds
Value	string	No	Nilai filter. Parameter ini tidak mendukung wildcard. Jika Key diatur ke DataFlowIds, atur Value ke ID alur data atau sebagian dari ID alur data. Anda dapat menentukan satu ID alur data atau sekelompok ID alur data. Maksimal 10 ID alur data dapat ditentukan. Contoh: `df-194433a5be31**` atau `df-194433a512a2,df-234533a5be31`. Jika Key diatur ke TaskId, atur Value ke ID tugas alur data atau sebagian dari ID tugas alur data. Anda dapat menentukan satu ID tugas alur data atau sekelompok ID tugas alur data. Maksimal 10 ID tugas alur data dapat ditentukan. Contoh: `task-38aa8e890f45` atau `task-38aa8e890f45,task-29ae8e890f45`. Jika Key diatur ke TaskActions, atur Value ke jenis tugas alur data. Jenis tugas dapat berupa Import, Export, Evict, Inventory, StreamImport, atau StreamExport**. Kueri gabungan didukung. CPFS for Lingjun hanya mendukung tugas Import, Export, StreamImport, dan StreamExport. Hanya CPFS for Lingjun V2.6.0 ke atas yang mendukung tugas StreamImport dan StreamExport. Jika Key diatur ke DataTypes, atur Value ke tipe data tugas alur data. Tipe data dapat berupa MetaAndData, Metadata, atau Data. Kueri gabungan didukung. Jika Key diatur ke Originator, atur Value ke inisiator tugas alur data. Inisiator dapat berupa User atau System. Jika Key diatur ke Status, atur Value ke status tugas alur data. Status dapat berupa Pending, Executing, Failed, Completed, Canceling, atau Canceled. Kueri gabungan didukung. Jika Key diatur ke CreateTimeBegin, atur Value ke awal rentang waktu pembuatan tugas alur data. Format waktu: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke CreateTimeEnd, atur Value ke akhir rentang waktu pembuatan tugas alur data. Format waktu: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke StartTimeBegin, atur Value ke awal rentang waktu mulai tugas alur data. Format waktu: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke StartTimeEnd, atur Value ke akhir rentang waktu mulai tugas alur data. Format waktu: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke EndTimeBegin, atur Value ke awal rentang waktu penghentian tugas alur data. Format waktu: `yyyy-MM-ddThh:mmZ`. Jika Key diatur ke EndTimeEnd, atur Value ke akhir rentang waktu penghentian tugas alur data. Format waktu: `yyyy-MM-ddThh:mmZ`.	df-194433a5be31****
NextToken	string	No	Token paginasi yang digunakan dalam permintaan berikutnya untuk mengambil halaman hasil baru. Anda tidak perlu menentukan parameter ini untuk permintaan pertama. Anda harus menentukan token yang diperoleh dari kueri sebelumnya sebagai nilai NextToken.	TGlzdFJlc291cmNlU****mVzJjE1MTI2NjY4NzY5MTAzOTEmMiZORnI4NDhVeEtrUT0=
MaxResults	integer	No	Jumlah hasil untuk setiap kueri. Nilai yang valid: 10 hingga 100. Nilai default: 20.	20
WithReports	boolean	No	Apakah akan menanyakan informasi laporan. True (default) False Catatan Atur ke False untuk mempercepat kueri. Hanya CPFS for Lingjun yang mendukung parameter ini.	True

Elemen respons

Element	Type	Description	Example
	object
RequestId	string	ID permintaan.	2D69A58F-345C-4FDE-88E4-BF518948****
NextToken	string	Token paginasi. Dapat digunakan dalam permintaan berikutnya untuk mengambil halaman hasil baru.	TGlzdFJlc291cmNlU****mVzJjE1MTI2NjY4NzY5MTAzOTEmMiZORnI4NDhVeEtrUT0=
TaskInfo	object
Task	array<object>	Informasi tentang tugas alur data.
	array<object>
FilesystemId	string	ID sistem file.	bmcpfs-290w65p03ok64ya****
DataFlowId	string	ID alur data.	df-194433a5be31****
TaskId	string	ID tugas alur data.	task-38aa8e890f45****
SourceStorage	string	Jalur akses penyimpanan sumber. Format: `<storage type>://[<account id>:]<path>`. Diantaranya: storage type: Hanya Object Storage Service (OSS) yang didukung. account id: UID akun penyimpanan sumber. path: nama bucket OSS. Batasan: Nama hanya boleh berisi huruf kecil, angka, dan tanda hubung (-). Nama harus diawali dan diakhiri dengan huruf kecil atau angka. Panjang nama maksimal 128 karakter. Nama harus dikodekan dalam UTF-8. Catatan Bucket OSS harus merupakan bucket yang sudah ada di wilayah tersebut. Hanya CPFS for Lingjun V2.6.0 ke atas yang mendukung parameter account id.	oss://178321033379****:bucket-01
FileSystemPath	string	Direktori fileset dalam sistem file CPFS. Batasan: Panjang direktori harus antara 2 hingga 1024 karakter. Direktori harus dikodekan dalam UTF-8. Direktori harus diawali dan diakhiri dengan garis miring (/). Direktori harus merupakan direktori fileset dalam sistem file CPFS. Catatan Hanya CPFS yang mendukung parameter ini.	/a/b/c/
Originator	string	Inisiator tugas alur data. Informasi berikut ditampilkan: User: Tugas diinisiasi oleh pengguna. System: Tugas diinisiasi secara otomatis oleh CPFS berdasarkan interval pembaruan otomatis. Catatan Hanya CPFS yang mendukung parameter ini.	User
TaskAction	string	Jenis tugas alur data. Informasi berikut ditampilkan: Import: mengimpor data yang disimpan di penyimpanan sumber ke sistem file CPFS. Export: mengekspor data tertentu dari sistem file CPFS ke penyimpanan sumber. StreamImport: mengimpor data tertentu dari penyimpanan sumber ke sistem file CPFS dalam mode streaming. StreamExport: mengekspor data tertentu dari sistem file CPFS ke penyimpanan sumber dalam mode streaming. Evict: melepaskan blok data file dalam sistem file CPFS. Setelah eviksi, hanya metadata file yang dipertahankan dalam sistem file CPFS. Anda masih dapat menanyakan file tersebut. Namun, blok data file dihapus dan tidak lagi menempati storage space dalam sistem file CPFS. Saat Anda mengakses data file, file tersebut dimuat dari penyimpanan sumber sesuai kebutuhan. Inventory: mendapatkan daftar inventaris yang dikelola oleh alur data dari sistem file CPFS, menyediakan status cache inventaris dalam alur data. Catatan Hanya CPFS for Lingjun V2.6.0 ke atas yang mendukung StreamImport dan StreamExport.	Import
DataType	string	Jenis data yang dioperasikan oleh tugas alur data. Informasi berikut ditampilkan: Metadata: metadata file, termasuk informasi timestamp, kepemilikan, dan izin file. Jika Anda memilih Metadata, hanya metadata file yang diimpor. Anda hanya dapat menanyakan file tersebut. Saat Anda mengakses data file, file tersebut 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	Kemajuan tugas alur data. Jumlah operasi yang telah dilakukan oleh tugas alur data.	50
Status	string	Status tugas alur data. Informasi berikut ditampilkan: Pending: Tugas alur data telah dibuat dan belum dimulai. Executing: Tugas alur data sedang dieksekusi. Failed: Tugas alur data gagal dieksekusi. Anda dapat melihat penyebab kegagalan dalam laporan tugas alur data. Completed: Tugas alur data selesai. Anda dapat memastikan bahwa semua file telah ditransfer dengan benar dalam laporan tugas alur data. Canceled: Tugas alur data dibatalkan dan tidak selesai. Canceling: Tugas alur data sedang dalam proses pembatalan.	Failed
ReportPath `deprecated`	string	Jalur penyimpanan laporan tugas alur data dalam sistem file CPFS. Laporan tugas untuk sistem file CPFS dihasilkan dalam direktori `.dataflow_report` sistem file CPFS. CPFS for Lingjun mengembalikan tautan unduh OSS agar Anda dapat mengunduh laporan tugas.	/path_in_cpfs/reportfile.cvs
CreateTime	string	Waktu saat tugas dibuat.	2021-08-04 18:27:35
StartTime	string	Waktu mulai tugas.	2021-08-04 18:27:35
EndTime	string	Waktu akhir tugas.	2021-08-04 18:27:35
FsPath	string	Jalur direktori cerdas.	/aa/
ConflictPolicy	string	Kebijakan konflik untuk file dengan nama yang sama. Nilai yang valid: SKIP_THE_FILE: melewati file dengan nama yang sama. KEEP_LATEST: membandingkan waktu pembaruan dan menyimpan versi terbaru. OVERWRITE_EXISTING: menimpa paksa file yang sudah ada.	KEEP_LATEST
Directory	string	Direktori tempat tugas alur data dieksekusi.	/path_in_cpfs/
DstDirectory	string	Direktori yang dipetakan ke tugas alur data.	/path_in_cpfs/
ErrorMsg	string	Penyebab pengecualian tugas. Catatan Jika parameter ini tidak dikembalikan atau nilai kembali kosong, berarti tidak terjadi error.	{"ErrorKey":"PATH_NOT_ACCESSIBLE","ErrorDetail":"lstat /cpfs/370lx1ev9ss27o****/test/abcdfnotfound: no such file or directory"}
ProgressStats	object	Kemajuan tugas alur data.
FilesTotal	integer	Jumlah file yang dipindai di sumber.	3
FilesDone	integer	Jumlah file (termasuk file yang dilewati) yang telah selesai diproses oleh tugas alur data.	3
ActualFiles	integer	Jumlah aktual file yang telah selesai diproses oleh tugas alur data.	3
BytesTotal	integer	Jumlah data yang dipindai di sumber. Satuan: byte.	131092971520
BytesDone	integer	Jumlah data (termasuk data yang dilewati) yang telah selesai diproses oleh tugas alur data. Satuan: byte.	131092971520
ActualBytes	integer	Jumlah aktual data yang telah selesai diproses oleh tugas alur data. Satuan: byte.	131092971520
RemainTime	integer	Perkiraan sisa waktu eksekusi. Satuan: detik.	437
AverageSpeed	integer	Kecepatan aliran rata-rata. Satuan: byte/detik.	342279299
Reports	object
Report	array<object>	Laporan. Catatan Tugas streaming tidak mendukung laporan. Jika parameter WithReport diatur ke True, data laporan CPFS for Lingjun akan dikembalikan. Hanya CPFS for Lingjun yang mendukung parameter WithReport.
	object
Name	string	Nama laporan. CPFS: TotalFilesReport: laporan tugas. CPFS for Lingjun: FailedFilesReport: laporan file gagal. SkippedFilesReport: laporan file dilewati. SuccessFilesReport: laporan file berhasil.	TotalFilesReport
Path	string	URL 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	Memfilter subdirektori dan mentransfer isinya. Catatan Hanya CPFS for Lingjun yang mendukung operasi ini.	["/test/","/test1/"]
TransferFileListPath	string	Menentukan direktori OSS dan menyinkronkan data berdasarkan konten file CSV di direktori OSS tersebut. Catatan Hanya CPFS for Lingjun yang mendukung operasi ini.	/path_in_cpfs/

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/\n",
        "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/\"]\n",
        "TransferFileListPath": "/path_in_cpfs/\n"
      }
    ]
  }
}

Kode kesalahan

HTTP status code	Error code	Error message
400	IllegalCharacters	The parameter contains illegal characters.
400	MissingFileSystemId	FileSystemId is mandatory for this action.
400	InvalidFilesystemVersion.NotSupport	This Api does not support this fileSystem version.
403	OperationDenied.DataFlowNotSupported	The operation is not supported.
404	InvalidParameter.InvalidNextToken	The specified NextToken is invaild.
404	InvalidFileSystem.NotFound	The specified file system does not exist.
404	InvalidDataFlow.NotFound	The specified data flow does not exist.
404	InvalidParameter.InvalidMaxResults	The specified MaxResults is invalid.
404	InvalidFilterParam	The specified Filter.N.Key is invalid.

Lihat Error Codes untuk daftar lengkap.

Catatan rilis

Lihat Release Notes untuk daftar lengkap.