a !f,@sdZddlZddlmZddlmZddlmZddlm Z ddZ d d Z Gd d d e ZGd ddeZGdddeZGdddeZGdddeZGddde ZddZdS)z@User friendly container for Google Cloud Bigtable Column Family.N) duration_pb2)_total_seconds) table_pb2)bigtable_table_admin_pb2cCs@t|}t|}|dkr$|jd}n|j}d|}tj||dS)aConvert a Python timedelta object to a duration protobuf. .. note:: The Python timedelta has a granularity of microseconds while the protobuf duration type has a duration of nanoseconds. :type timedelta_val: :class:`datetime.timedelta` :param timedelta_val: A timedelta object. :rtype: :class:`google.protobuf.duration_pb2.Duration` :returns: A duration object equivalent to the time delta. ri@Bi)secondsnanos)rint microsecondsrZDuration)Z timedelta_valZseconds_decimalrZ signed_microsrr ^/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/bigtable/column_family.py_timedelta_to_duration_pbs r cCstj|j|jddS)aConvert a duration protobuf to a Python timedelta object. .. note:: The Python timedelta has a granularity of microseconds while the protobuf duration type has a duration of nanoseconds. :type duration_pb: :class:`google.protobuf.duration_pb2.Duration` :param duration_pb: A protobuf duration object. :rtype: :class:`datetime.timedelta` :returns: The converted timedelta object. g@@)rr )datetime timedeltarr)Z duration_pbr r r _duration_pb_to_timedelta7src@seZdZdZddZdS)GarbageCollectionRuleaGarbage collection rule for column families within a table. Cells in the column family (within a table) fitting the rule will be deleted during garbage collection. .. note:: This class is a do-nothing base class for all GC rules. .. note:: A string ``gc_expression`` can also be used with API requests, but that value would be superceded by a ``gc_rule``. As a result, we don't support that feature and instead support via native classes. cCs || SN__eq__selfotherr r r __ne__\szGarbageCollectionRule.__ne__N)__name__ __module__ __qualname____doc__rr r r r rKsrc@s(eZdZdZddZddZddZdS) MaxVersionsGCRulezGarbage collection limiting the number of versions of a cell. :type max_num_versions: int :param max_num_versions: The maximum number of versions cCs ||_dSrmax_num_versions)rrr r r __init__gszMaxVersionsGCRule.__init__cCst||jsdS|j|jkSNF) isinstance __class__rrr r r rjs zMaxVersionsGCRule.__eq__cCstj|jdS)Converts the garbage collection rule to a protobuf. :rtype: :class:`.table_v2_pb2.GcRule` :returns: The converted current object. r) table_v2_pb2GcRulerrr r r to_pboszMaxVersionsGCRule.to_pbNrrrrrrr'r r r r r`src@s(eZdZdZddZddZddZdS) MaxAgeGCRulezGarbage collection limiting the age of a cell. :type max_age: :class:`datetime.timedelta` :param max_age: The maximum age allowed for a cell in the table. cCs ||_dSrmax_agerr+r r r rszMaxAgeGCRule.__init__cCst||jsdS|j|jkSr )r!r"r+rr r r rs zMaxAgeGCRule.__eq__cCst|j}tj|dS)r#r*)r r+r$r%r,r r r r's zMaxAgeGCRule.to_pbNr(r r r r r)xsr)c@s(eZdZdZddZddZddZdS) GCRuleUnionzxUnion of garbage collection rules. :type rules: list :param rules: List of :class:`GarbageCollectionRule`. cCs ||_dSrrulesrr/r r r rszGCRuleUnion.__init__cCst||jsdS|j|jkSr r!r"r/rr r r rs zGCRuleUnion.__eq__cCs&tjjdd|jDd}tj|dS)zConverts the union into a single GC rule as a protobuf. :rtype: :class:`.table_v2_pb2.GcRule` :returns: The converted current object. cSsg|] }|qSr r'.0ruler r r z%GCRuleUnion.to_pb..r.)union)r$r%Unionr/)rr8r r r r'szGCRuleUnion.to_pbNr(r r r r r-sr-c@s(eZdZdZddZddZddZdS) GCRuleIntersectionzIntersection of garbage collection rules. :type rules: list :param rules: List of :class:`GarbageCollectionRule`. cCs ||_dSrr.r0r r r rszGCRuleIntersection.__init__cCst||jsdS|j|jkSr r1rr r r rs zGCRuleIntersection.__eq__cCs&tjjdd|jDd}tj|dS)zConverts the intersection into a single GC rule as a protobuf. :rtype: :class:`.table_v2_pb2.GcRule` :returns: The converted current object. cSsg|] }|qSr r2r3r r r r6r7z,GCRuleIntersection.to_pb..r.) intersection)r$r%Z Intersectionr/)rr;r r r r'szGCRuleIntersection.to_pbNr(r r r r r:sr:c@sVeZdZdZdddZeddZddZd d Zd d Z d dZ ddZ ddZ dS) ColumnFamilyaRepresentation of a Google Cloud Bigtable Column Family. We can use a :class:`ColumnFamily` to: * :meth:`create` itself * :meth:`update` itself * :meth:`delete` itself :type column_family_id: str :param column_family_id: The ID of the column family. Must be of the form ``[_a-zA-Z0-9][-_.a-zA-Z0-9]*``. :type table: :class:`Table ` :param table: The table that owns the column family. :type gc_rule: :class:`GarbageCollectionRule` :param gc_rule: (Optional) The garbage collection settings for this column family. NcCs||_||_||_dSr)column_family_id_tablegc_rule)rr=tabler?r r r rszColumnFamily.__init__cCs|jjd|jS)aoColumn family name used in requests. .. note:: This property will not change if ``column_family_id`` does not, but the return value is not cached. The table name is of the form ``"projects/../zones/../clusters/../tables/../columnFamilies/.."`` :rtype: str :returns: The column family name. z/columnFamilies/)r>namer=r&r r r rAszColumnFamily.namecCs4t||jsdS|j|jko2|j|jko2|j|jkSr )r!r"r=r>r?rr r r rs    zColumnFamily.__eq__cCs || Srrrr r r rszColumnFamily.__ne__cCs(|jdurtStj|jdSdS)zConverts the column family to a protobuf. :rtype: :class:`.table_v2_pb2.ColumnFamily` :returns: The converted current object. N)r?)r?r$r<r'r&r r r r's zColumnFamily.to_pbcCsH|}tj|jjd}|jj|j|d|jjj }|j ||j dS)zCreate this column family.rA)idcreateN r'table_admin_v2_pb2ModifyColumnFamiliesRequestr>rA modificationsaddr= _instance_client _table_stubModifyColumnFamiliestimeout_secondsrZ column_family request_pbclientr r r rDs zColumnFamily.createcCsH|}tj|jjd}|jj|j|d|jjj }|j ||j dS)zUpdate this column family. .. note:: Only the GC rule can be updated. By changing the column family ID, you will simply be referring to a different column family. rB)rCupdateNrErOr r r rRs zColumnFamily.updatecCs@tj|jjd}|jj|jdd|jjj}|j ||j dS)zDelete this column family.rBT)rCZdropN) rFrGr>rArHrIr=rJrKrLrMrN)rrPrQr r r delete+s zColumnFamily.delete)N) rrrrrpropertyrArrr'rDrRrSr r r r r<s   r<cCs|d}|durdS|dkr(t|jS|dkrBt|j}t|S|dkr`tdd|jjDS|dkrd d|j jD}t |St d |dS) aConvert a protobuf GC rule to a native object. :type gc_rule_pb: :class:`.table_v2_pb2.GcRule` :param gc_rule_pb: The GC rule to convert. :rtype: :class:`GarbageCollectionRule` or :data:`NoneType ` :returns: An instance of one of the native rules defined in :module:`column_family` or :data:`None` if no values were set on the protobuf passed in. :raises: :class:`ValueError ` if the rule name is unexpected. r5Nrr+r8cSsg|] }t|qSr _gc_rule_from_pbr3r r r r6Osz$_gc_rule_from_pb..r;cSsg|] }t|qSr rUr3r r r r6RszUnexpected rule name) Z WhichOneofrrrr+r)r-r8r/r;r: ValueError)Z gc_rule_pbZ rule_namer+r/r r r rV8s$   rV)rr Zgoogle.protobufrZgcloud._helpersrZgcloud.bigtable._generatedrr$rrFr robjectrrr)r-r:r<rVr r r r s    s