user
11/23/2022, 6:28 PMlakefs
under the current user. Can we customize where lakefs
can be?user
11/23/2022, 6:32 PMblockstore:
type: local
local:
path: "/path/to/data"
Then run lakeFS like so:
lakefs run --local-settings --config example-config.yaml
user
11/23/2022, 6:35 PMuser
11/23/2022, 6:43 PM"/path/to/data"
here it means the path for`lakefs` or lakefs/data
?user
11/23/2022, 6:45 PMuser
11/23/2022, 6:46 PMlakefs/data/block
?user
11/23/2022, 6:47 PMuser
11/23/2022, 6:48 PMuser
11/23/2022, 6:48 PMuser
11/23/2022, 6:50 PMuser
11/23/2022, 6:53 PMuser
11/23/2022, 7:01 PMlakefs run --config s3.yaml
due to sse issue, I am trying to mount s3 as local storage and load data on it. I found lakefs created a folder called lakefs
which has sub-folder data
and metadata
. lakefs/data/block
is the place to keep files. Folder lakefs
is under current user who run the lakefs. If I want to put lakefs
on the mounted S3 local storage, how to do it.user
11/23/2022, 7:10 PMuser
11/23/2022, 7:17 PM"/path/to/data"
in config is the path for lakefs/data/block
user
11/23/2022, 7:18 PMuser
11/23/2022, 7:20 PMuser
11/28/2022, 3:26 PMuser
11/28/2022, 3:45 PMuser
11/28/2022, 3:47 PMuser
11/28/2022, 3:52 PMuser
11/28/2022, 3:52 PMuser
11/28/2022, 3:53 PMuser
11/28/2022, 3:53 PMuser
11/28/2022, 3:53 PMfrom lakefs_client.client import LakeFSClient
user
11/28/2022, 3:54 PMclient.repositories.<method>
for all api calls associated with repositoriesuser
11/28/2022, 3:55 PMuser
11/28/2022, 3:58 PMuser
11/28/2022, 4:00 PMclient.repositories.<method>
where I can find docs for it?user
11/28/2022, 4:02 PMuser
11/28/2022, 4:04 PMuser
11/28/2022, 4:04 PMuser
11/28/2022, 4:05 PMuser
11/28/2022, 4:05 PMuser
11/28/2022, 4:05 PMuser
11/28/2022, 4:06 PMclass LakeFSClient:
def __init__(self, configuration=None, header_name=None, header_value=None, cookie=None, pool_threads=1):
if configuration:
configuration = LakeFSClient._ensure_endpoint(configuration)
self._api = _WrappedApiClient(configuration=configuration, header_name=header_name,
header_value=header_value, cookie=cookie, pool_threads=pool_threads)
for key, value in inspect.getmembers(sys.modules['lakefs_client.apis'], inspect.isclass):
name = key.lower()
if not name.endswith(_API_CLASS_SUFFIX):
continue
api_instance = value(self._api)
attr_name = name[:-len(_API_CLASS_SUFFIX)]
setattr(self, attr_name, api_instance)
setattr(self, attr_name + '_api', api_instance)
user
11/28/2022, 4:06 PMuser
11/28/2022, 4:07 PMuser
11/28/2022, 4:07 PMuser
11/28/2022, 4:08 PMuser
11/28/2022, 4:12 PMuser
11/28/2022, 4:14 PMuser
11/28/2022, 4:15 PMuser
11/28/2022, 4:16 PMuser
11/28/2022, 4:18 PM