1import ray
2from lance_ray import read_lance
3import lance
4from lance_namespace import RegisterTableRequest
5from lance_ray.utils import get_or_create_namespace
6
7@ray.remote
8def register_lance_table():
9    register_req = RegisterTableRequest(
10        id=["{existing catalog}", "{existing database}", "{new table name}"],
11        location="bos://xxx-bucket/xxxxxx/metastore/xxxxxx/catalogs/xxxxxx/schemas/xxxxxx/tables/xxxxxxxxxxxxxxxx",
12        properties={
13            "fs.bos.access.key": "{bos access key}",
14            "fs.bos.secret.access.key": "{bos secret key}",
15        },
16    )
17    namespace = get_or_create_namespace("rest", {})
18    namespace.register_table(register_req)
19    return "register success"
20
21print("start register")
22print(ray.get(register_lance_table.remote()))
23print("end register")