Ronnie Ning
11/23/2022, 6:28 PMlakefs
under the current user. Can we customize where lakefs
can be?Yoni Augarten
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
Ronnie Ning
11/23/2022, 6:35 PM"/path/to/data"
here it means the path for`lakefs` or lakefs/data
?Yoni Augarten
11/23/2022, 6:45 PMRonnie Ning
11/23/2022, 6:46 PMlakefs/data/block
?Yoni Augarten
11/23/2022, 6:47 PMRonnie Ning
11/23/2022, 6:50 PMIddo Avneri
11/23/2022, 6:53 PMRonnie Ning
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.Yoni Augarten
11/23/2022, 7:10 PMRonnie Ning
11/23/2022, 7:17 PM"/path/to/data"
in config is the path for lakefs/data/block
Niro
11/23/2022, 7:18 PMRonnie Ning
11/23/2022, 7:20 PMBarak Amar
11/28/2022, 3:45 PMRonnie Ning
11/28/2022, 3:47 PMBarak Amar
11/28/2022, 3:52 PMfrom lakefs_client.client import LakeFSClient
client.repositories.<method>
for all api calls associated with repositoriesRonnie Ning
11/28/2022, 3:55 PMBarak Amar
11/28/2022, 3:58 PMRonnie Ning
11/28/2022, 4:00 PMclient.repositories.<method>
where I can find docs for it?Barak Amar
11/28/2022, 4:02 PMRonnie Ning
11/28/2022, 4:04 PMBarak Amar
11/28/2022, 4:05 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)
Ronnie Ning
11/28/2022, 4:12 PMBarak Amar
11/28/2022, 4:14 PMRonnie Ning
11/28/2022, 4:18 PM