你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
AzureDLFile 类
以文件的形式打开 ADL 密钥。 仅按需加载和缓存数据。
- 继承
-
builtins.objectAzureDLFile
构造函数
AzureDLFile(azure, path, mode='rb', blocksize=33554432, delimiter=None)
参数
名称 | 说明 |
---|---|
azure
必需
|
<xref:<xref:azure.datalake.store.core.azure connection>>
|
path
必需
|
文件的位置 |
mode
|
默认值: rb
|
blocksize
|
写入或预读缓冲区的大小。 对于写入 (和追加,将被截断为 4MB (2**22) 。 默认值: 33554432
|
delimiter
|
如果指定并且处于写入模式,则每次刷新都会在此字节数上发送终止数据,这可能会在缓冲区中保留一些数据。 默认值: None
|
示例
>>> adl = AzureDLFileSystem()
>>> with adl.open('my-dir/my-file.txt', mode='rb') as f:
... f.read(10)
方法
close |
关闭文件 如果处于写入模式,则会导致刷新任何未写入的数据。 |
flush |
将缓冲数据写入 ADL。 不带分隔符:上传当前缓冲区。 使用分隔符:写入小于或等于块大小的数据量,该大小在分隔符上结束,直到缓冲区小于块大小。 如果块中没有分隔符,则上传整个块。 如果 force=True,则刷新缓冲区中的所有数据,即使它未以分隔符结尾;在关闭文件时适当。 |
info |
有关此路径的文件信息 |
next | |
read |
从缓存返回数据,或根据需要提取部分 |
read1 |
从缓存返回数据,或根据需要提取部分 |
readable |
返回是否已打开 AzureDLFile 进行读取 |
readinto |
将数据读入缓冲区 b |
readline |
从流中读取并返回一行。 如果指定了 length,则最多将读取大小字节。 |
readlines |
以列表的形式返回文件中的所有行 |
seek |
设置当前文件位置 |
seekable |
返回 AzureDLFile 是否仅在读取模式下 (可查找) |
tell |
当前文件位置 |
writable |
返回是否已打开 AzureDLFile 进行写入 |
write |
将数据写入缓冲区。 缓冲区仅在刷新 () 时或缓冲区大于块大小时才发送到 ADL。 |
close
关闭文件
如果处于写入模式,则会导致刷新任何未写入的数据。
close()
flush
将缓冲数据写入 ADL。
不带分隔符:上传当前缓冲区。
使用分隔符:写入小于或等于块大小的数据量,该大小在分隔符上结束,直到缓冲区小于块大小。 如果块中没有分隔符,则上传整个块。
如果 force=True,则刷新缓冲区中的所有数据,即使它未以分隔符结尾;在关闭文件时适当。
flush(syncFlag='METADATA', force=False)
参数
名称 | 说明 |
---|---|
syncFlag
|
默认值: METADATA
|
force
|
默认值: False
|
info
有关此路径的文件信息
info()
next
next()
read
read1
readable
返回是否已打开 AzureDLFile 进行读取
readable()
readinto
将数据读入缓冲区 b
readinto(b)
参数
名称 | 说明 |
---|---|
b
必需
|
将字节读入到的缓冲区 |
返回
类型 | 说明 |
---|---|
<xref:Returns> <xref:number> <xref:of> bytes <xref:read.>
|
readline
从流中读取并返回一行。
如果指定了 length,则最多将读取大小字节。
readline(length=-1)
参数
名称 | 说明 |
---|---|
length
|
默认值: -1
|
readlines
以列表的形式返回文件中的所有行
readlines()
seek
seekable
返回 AzureDLFile 是否仅在读取模式下 (可查找)
seekable()
tell
当前文件位置
tell()
writable
返回是否已打开 AzureDLFile 进行写入
writable()
write
反馈
https://aka.ms/ContentUserFeedback。
即将发布:在整个 2024 年,我们将逐步淘汰作为内容反馈机制的“GitHub 问题”,并将其取代为新的反馈系统。 有关详细信息,请参阅:提交和查看相关反馈