Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
boto
/
services
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: service.cpython-310.pyc
o ckF[� � @ sd d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dl Z d dl Z d dl Z G dd� de�Z dS )� N)�ServiceMessage)� ServiceDef)� ScriptBase)�get_tsc s~ e Zd ZdZd � fdd� Zdd� Zdd� Zd d � Zd d � Zd d d�Z dd� Z dd� Z dd� Z dd� Z dd� Zd dd�Z� ZS ) �Service�< Nc s� t t| ��|� | jj| _tj�dd�| _ t |�| _ | j � dd�| _ | j � dd�| _| j � dd�| _| j �d �| _| j �d �| _| j �d �| _|rPt�|� d S d S ) N�Pyami� working_dir� retry_count� � loop_delay� �processing_timer � input_queue� output_queue� output_domain)�superr �__init__� __class__�__name__�name�boto�config�getr r �sd�getintr r r �get_objr r r � mimetypes�init)�self� config_file�mimetype_files�r � �7/usr/lib/python3/dist-packages/boto/services/service.pyr % s �zService.__init__c C sB | � d�dk r | df}|S | �d�\} }|�d�\}}| |f}|S )N�;r � �=)�find�split)�key�t�type�label�mtyper# r# r$ � split_key3 s �zService.split_keyc C s@ t j�d� | j�| j�}|r t j�|�� � d}t� ||< |S )N� read_messagez Service-Read)r �log�infor �readr �get_bodyr )r �messager* r# r# r$ r0 < s zService.read_messagec C sn |d }|d }t j�| j|�dd��}tj�d|||f � t�d|�}|� |�}|� t j�| j|�� |S )N�Bucket�InputKey�OriginalFileName�in_filezget_file: %s/%s to %s�s3) �os�path�joinr r r r1 r2 �lookup�new_key�get_contents_to_filename)r r5 � bucket_name�key_name� file_name�bucketr* r# r# r$ �get_fileF s zService.get_filec C s g S �Nr# )r � in_file_name�msgr# r# r$ � process_fileQ � zService.process_filec C s: t j�d|||f � t �d|�}|�|�}|�|� |S )Nzputting file %s as %s.%sr: )r r1 r2 r> r? �set_contents_from_filename)r rA � file_pathrB rD r* r# r# r$ �put_fileU s zService.put_filec C sp g }|D ]*\}}d|v r|d }n|d }t j�|�d }| �|||�} |�d| j|f � qd�|�|d< d S )N� OutputBucketr6 � z %s;type=%s�,� OutputKey)r; r< r) rM �appendr r= ) r �results� input_message�output_message� output_keys�filer, � output_bucketrB r* r# r# r$ � save_results\ s zService.save_resultsc C s� t � |d< | j|d< dtjv rtjd |d< nd|d< | j|d< | jr3tj�d| jj � | j� |� | j rWtj�d| j j � d � |d |d |d g�}| j � ||� d S d S ) Nz Service-Write�Server�HOSTNAME�Host�unknownz Instance-IDz Writing message to SQS queue: %sz!Writing message to SDB domain: %s�/r6 r7 )r r r; �environ� instance_idr r r1 r2 �id�writer r= �put_attributes)r r5 � item_namer# r# r$ � write_messagei s �zService.write_messagec C s$ t j�d| jj � | j�|� d S )Nzdeleting message from %s)r r1 r2 r ra �delete_message)r r5 r# r# r$ rf z s zService.delete_messagec C s d S rF r# )r r# r# r$ �cleanup rJ zService.cleanupc C sH | j �dd�}|dkr | jr"t�d� t�� }|�| jg� d S d S d S )N� on_completion�shutdownr )r r r` �time�sleepr � connect_ec2�terminate_instances)r rh �cr# r# r$ ri � s �zService.shutdownFc C s� | � d| j � d}| jdk s|| jk rnz<| �� }|rEd}td |�� �}| �|�}| �||�}| �|||� | � |� | � |� | � � n |d7 }t � | j� W n tyc tj�d� |d7 }Y nw | jdk s|| jk s| � d| j � | �� d S )NzService: %s Startingr rO zService FailedzService: %s Shutting Down)�notifyr r r0 r r4 rE rI rY re rf rg rj rk r � Exceptionr r1 � exceptionri )r ro � empty_readsrT rU � input_filerS r# r# r$ �main� s0 � �� z Service.main)NNrF )F)r � __module__� __qualname__�ProcessingTimer r/ r0 rE rI rM rY re rf rg ri rt � __classcell__r# r# r" r$ r s r ) r �boto.services.messager �boto.services.servicedefr �boto.pyami.scriptbaser � boto.utilsr rj r; r r r# r# r# r$ �<module> s
Save
Cancel