+dWddlmZddlmZddlmZddlmZddlm Z ee eeedZ ee Z gdZ dd Z d Zd Zd S)) RemoteCatalog)ContainerRegistryView)RemoteDataFrame) RemoteArray)RemoteSequenceSource) dataframepythonndarraynumpycatalog) container_mapregister_containerunregister_containerFc |tvr9|s7t|}||urdStd|d|dt|d|t|<dS)a] Add to the container registry, ``intake.container.container_map``. Parameters ---------- name: string container: DataSource overwrite: bool, optional False by default. Raises ------ ValueError If name collides with an existing name in the container registry and overwrite is False. NzThe container z& could not be registered for the name z because zE is already registered for that name. Use overwrite=True to force it.)_container_map ValueError)name container overwriteoriginals 9lib/python3.11/site-packages/intake/container/__init__.pyrrs" ~  i  !$' y   F IY I I I I#1$#7 I I I   %N4c8t|dS)a Ensure that a given name in the container registry is cleared. This function is idempotent: if the name does not exist in ``intake.container.container_map``, nothing is done, and the function returns None Parameters ---------- name: string Returns ------- container: DataSource or None Whatever was registered for ``name``, or ``None`` N)rpop)rs rrr4s"   dD ) ))rc tD](} |j||fi|}||cS#t$rY%wxYwt d)aGiven a concrete data object, store it at given location return Source Use this function to publicly share data which you have created in your python session. Intake will try each of the container types, to see if one of them can handle the input data, and write the data to the path given, in the format most appropriate for the data type, e.g., parquet for pandas or dask data-frames. With the DataSource instance you get back, you can add this to a catalog, or just get the YAML representation for editing (``.yaml()``) and sharing. Parameters ---------- data : instance The object to upload and store. In many cases, the dask or in-memory variant are handled equivalently. path : str Location of the output files; can be, for instance, a network drive for sharing over a VPC, or a bucket on a cloud storage service kwargs : passed to the writer for fine control Returns ------- DataSource instance Nz#No class found to handle given data)rvalues_data_to_sourceNotImplementedError TypeError)datapathkwargsclsss ruploadr&Hs6##%% ##D$99&99A  "    D  9 : ::s3 AAN)F)catalog.remoterutilsrr rr rsemistructuredrrr__all__rrr&rrr,s+*****))))))&&&&&& 000000 /:N[fq|JWXX%%n55 I I I%%%%<***(";";";";";r